彈簧雲流和動物園管理員

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。