Nachricht wird zweimal verbraucht

Question

Es gibt ein Thema mit 8 Partitionen in einem Kafka-Cluster. Ich implementiert Anwendung, um das Thema mit KafkaMessageDrivenChannelAdapter, die gleichzeitig 8 ist und OffsetManager ist KafkaTopicOffsetManager. Wenn ich eine Anwendungsinstanz starte, stimmt alles. Aber wenn ich zwei Anwendungsinstanzen starte, finde ich, dass die Meesge zweimal konsumiert wird. Weißt du warum und wie man es löst? Ich muss zum highLevelConsumer wechseln?

Answer 1

Sie müssen die Partitionen über Instanzen mit diesem Adapter verteilen.

Wir arbeiten an der Aktualisierung auf Kafka 0.9 Java Clients, die Verbrauchergruppen unterstützt.

The first milestone for the core project is available.

Wir müssen daran arbeiten, einen Meilenstein von Frühjahr-Integration-Kafka 2.0 zu veröffentlichen, die diesen neuen Client verwendet.