spring-cloud-stream-kafka不尊重單個消費者的羣體

我正在使用spring-cloud-stream-kafka。我從卡夫卡話題testTopic與單個分區啓動消費應用的兩個實例使用相同的組名testGroup消費消息，我預計消費者一個實例爲使用來自卡夫卡的話題，其他實例的消息不消費任何東西，因爲他們共享相同的組名稱。我正在使用0.8.xx版本的Kafka客戶端。這裏是我的物業spring-cloud-stream-kafka不尊重單個消費者的羣體

spring.cloud.stream.bindings.input.destination=testTopic 

spring.cloud.stream.bindings.input.group=testGroup

任何想法可能發生什麼？

來源

2016-11-15 Amit Bartake

您正在使用哪個版本的Spring Cloud Stream？我想你使用的是支持Kafka 0.8.xx版本的Spring Cloud Stream的1.0.3版本。無論如何，這看起來像一個錯誤。

另外，在Spring Cloud Stream 1.1.x中使用Kafka 0.9或0.10時，我沒有看到這個問題。

來源

2016-11-15 09:38:21

我使用Brixton.SR6其中拉動彈簧雲起動流卡夫卡（1.0.2.RELEASE） –

沒錯，那是我們使用SimpleConsumer API時1.0.3/0.8的預期行爲。您無需在1.1之後執行此操作 - 詳情請參閱http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/index.html#_instance_index_and_instance_count。

來源

2016-11-15 16:03:16

這是否意味着我不能有與單個分區一個主題並具有相同的基團指向2個消費者實例它只有一個實例正在消費消息。我需要爲彈性設置多個消費者實例 –

否，這意味着您需要按照鏈接中的說明進行操作，併爲每個正在運行的實例相應地配置實例索引和實例計數。 –

spring-cloud-stream-kafka不尊重單個消費者的羣體

回答

相關問題