春云流与动物园管理员

Question

我有两个应用程序：

• 第一个在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。 那么你能解释一下它什么时候可以使用吗，或者你能给我一个我必须定义动物园管理员相关属性的用例吗？

Answer 1

Zookeeper 用于允许 Kafka binder 自动创建主题（使用 binder 选项，例如分区计数或并发实例数 - 而不是依赖于 broker 来创建它们）。如果您不需要该功能，您可以禁用主题自动创建。 请参阅此处的讨论：https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/37。

这是从 1.1 开始提供的功能。在 1.0 中，SimpleConsumer 客户端需要 Zookeeper。