1 zk各ホスティングとそれぞれに、3 つの個別の物理ノードの Kafka クラスターがあり1 brokerます。Kafka 0.10.1.1 を使用しています。トピックは ZK アンサンブルで作成され、ブローカーは ZK アンサンブルに接続します。私のProducerとConsumerは、Spring Boot アプリです (バージョン 1.5.13 RELEASE)。単一パーティション (つまり - Partition 0)min.insync.replicas=2とreplication_factor=3. これまでのところ、--describeトピックを確認すると、すべてのレプリカが同期されていることがわかります。コンシューマー グループを登録すると、コンシューマー グループがアクティブな場合にのみ、CLI と Kafka-Manager で表示されることがわかりました。ここまでは大丈夫です。
監視zk:2181のために個別のクラスターとして個別に追加しました。Kafka-managerがアクティブでない場合でもconsumer groups、いくつかのクラスター (つまり飼育係) に異なるラグ値で表示されています。特定のトピックのラグが表示されるノードは、同じトピックのリーダーでもありません。CLI を使用してクロスチェックすると、コンシューマ グループは を除いて表示されませんKMOffsetCache-<<instance-name>>。kafka-consumer-groups.sh --bootstrap-server ...
zk(s) または consumer_offsets が正しく同期されていないようです。理由を知りたいのですが？同じことを修正する方法は？