弹簧云流和动物园管理员

Question

我有两种应用：在卡夫卡

• 第一个产生消息
• 第二个接收所有这些消息

我已经配置 spring.cloud.stream.kafka.binder.brokers和spring.cloud.stream.kafka.binder.defaultBrokerPort。 一切正常。

在本文档中我看到 spring.cloud.stream.kafka.binder.zkNodes和spring.cloud.stream.kafka.binder.defaultZkPort 来定义该卡夫卡粘结剂可以连接ZooKeeper的节点列表。

在我的理解中，我只需要将我的应用程序连接到kafka。 所以你可以解释我什么时候可用，或者你可以给我一个用例，我必须定义动物园管理员的相关属性。

Answer 1

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

这是自1.1以来的一项功能。 0.8 SimpleConsumer客户端需要1.0 Zookeeper。