1つのパーティションでカフカトピックの同時メッセージリスナーを作成する方法

Question

Uusing Spring Kafka org.springframework.kafka.listener.ConcurrentMessageListenerContainerは、トピック内のパーティション数とContainerPropertiesに基づいて複数のリスナーを作成します。 javadocには、「同じパーティション内のメッセージは順次処理されます」と表示されます。したがって、パーティションが1つしかなく、並行性が10と設定されている場合、何が起こるでしょうか？並行性はありません。またはメッセージは10人のリスナーに配布されますが、順序が乱れますか？

Answer 1

いいえ、ターゲットリスナーは1つだけです。 1つのパーティション - コンシューマ・グループごとに1つのプロセス。それはApache Kafkaの性質です。それは春のカフカ問題ではありません。

最近、そのパーティションからのメッセージを、リスナーの方法から並列化することができます（TaskExecutor）。しかし、それはすでにあなたのアプリケーションです。このフレームワークはあなたにとって何もしません。ちょうどターゲットカフカシステムの性質。