我有两个应用程序:
- 第一个在 kafka 中生成消息
- 第二个收到所有这些消息
我已经配置了
spring.cloud.stream.kafka.binder.brokers和spring.cloud.stream.kafka.binder.defaultBrokerPort 。
一切正常。
在文档中我看到
spring.cloud.stream.kafka.binder.zkNodes和spring.cloud.stream.kafka.binder.defaultZkPort
定义 Kafka Binder 可以连接的 ZooKeeper 节点列表。
根据我的理解，我只需将我的应用程序连接到kafka。 那么您能否解释一下它何时可用，或者您能否给我一个必须定义 Zookeeper 相关属性的用例。
最佳答案
Zookeeper 用于允许 Kafka 绑定(bind)器自动创建主题(使用绑定(bind)器选项，例如分区计数或并发实例数 - 而不是依赖代理来创建它们)。如果您不需要该功能，可以禁用主题自动创建。 请参阅此处的讨论:https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/37 .
这是自 1.1 起提供的功能。在 1.0 中，0.8 SimpleConsumer 客户端需要 Zookeeper。
关于java - Spring Cloud 溪流和动物园管理员，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40300682/