6

Kafka でトピックを作成した後、それらのグループを使用してトピックから読み取ろうとするだけで、任意の数のコンシューマー グループを作成できます。

実際のコンシューマー グループのメッセージ コンテンツを監視するために、追加のコンシューマー グループを作成したいと考えています。したがって、GUI では、任意のコンシューマ グループで「peek」をクリックすると、「peeker」グループのオフセットが監視対象のグループのオフセットに更新され、そのオフセットからのメッセージが表示されます。

初めて消費者グループを明示的に作成することはできないため、私は混乱しています。Zookeeper で作成されたオフセット ノードを取得するには、メッセージを読む必要があるようです。

私の質問

特定のオフセットを指す消費者グループを明示的に作成する方法はありますか、またはまだ使用されていない消費者グループの Zookeeper ノードを手動で作成して、正しいオフセット値に初期化しても問題ありませんか? それとも、この自動作成によってコンシューマー グループの割り当てプロセスが台無しになるのでしょうか?

4

3 に答える 3

2

あなたが説明したものと同様のことをすでに行っているKafka Web Consoleプロジェクトを見ることができます。

これを自分で行いたい場合は、シンプルなコンシューマー API を使用して、新しいコンシューマー グループ (Zookeeper または他の場所に格納されている) のオフセットを手動で処理する必要があります。既存のコンシューマー グループから現在のオフセットを取得し、ピーク グループの同じオフセットを使用してメッセージを読み取ることができます。グループ ID が異なる限り、互いに干渉したり混乱したりしてはなりません。

于 2015-01-26T20:56:56.253 に答える