カフカ消費者がポーリングすることができません

Question

カフカのコンシューマアプリケーションがカフカからメッセージを読み込んでいる場合、別のものが読み込めず、その逆もありません。

私たちは2つの独立したアプリケーションを実行しています.1つはメッセージを処理し、もう1つはデータベースに読み込んで入れます。最初のアプリケーションで処理されている

メッセージ :-)私はあなたが唯一のパーティションとしてトピックを持っていると思います...私は推測することができ、コードを見ることなく第二のアプリケーション

Answer 1

では使用できません。両方のコンシューマアプリケーションが同じコンシューマグループに属しています。この場合、1つのコンシューマだけがトピックの1つのパーティションからメッセージを取得します。 両方のアプリケーションが同じトピックからのメッセージを受信するようにするには、それらを異なるコンシューマグループ（コンシューマプロパティのgroup.idパラメータ）に配置する必要があります。