メッセージが2回消費される

Question

カフカクラスタに8つのパーティションがあるトピックがあります。 私は、KafkaMessageDrivenChannelAdapterでトピックを消費するアプリケーションを実装しました。これは、concurrentが8で、offsetManagerがKafkaTopicOffsetManagerです。 1つのアプリケーションインスタンスを起動すると、すべて正しいです。しかし、2つのアプリケーションインスタンスを起動すると、meesgeが2回消費されることがわかります。なぜ、どうやってそれを解決するのか分かりますか？私はhighLevelConsumerへの変更が必要ですか？

Answer 1

パーティションをそのアダプタを使用して複数のインスタンスに分散する必要があります。

私たちは、消費者グループをサポートするkafka 0.9 Javaクライアントへのアップグレードに取り組んでいます。

The first milestone for the core project is available。

この新しいクライアントを使用するspring-integration-kafka 2.0のマイルストーンをリリースする必要があります。