消息被消耗兩次

Question

在Kafka集羣中有一個包含8個分區的主題。 我使用KafkaMessageDrivenChannelAdapter來實現應用程序，以使用併發數爲8且offsetManager爲KafkaTopicOffsetManager的主題。 當我啓動一個應用程序實例時，一切都是正確的。但是當我啓動兩個應用程序實例時，我發現meesge被消耗了兩次。你知道爲什麼以及如何解決它嗎？我需要改變成highLevelConsumer？

Answer 1

您必須使用該適配器跨實例分配分區。

我們正在努力升級到支持消費者羣體的kafka 0.9 java客戶端。

The first milestone for the core project is available。

我們需要努力發佈一個使用這個新客戶端的spring-integration-kafka 2.0的里程碑。