2016-04-06 3 views
0

私は、マルチパーティションのトピックを作成し、それらを読み込み、それらから消費者で読むことができるKafkaアプリケーションを持っています。それはうまくいくようです。なぜカフカ0.9.0.1で消費者を見ることができないのですか?

私はカフカの可視性を取得しようとしているので、私はkafka-managerとtrifectaのようなツールをいくつか試しました。これらのツールは私のトピックやパーティションなどについて教えてくれますが、私の消費者がそれらのオフセットを取得するのを見ていないようです。

カフカのトピックを見ると、私の話題に__consumer_offsetsと表示されています。これは、カフカ(Zookeeperではなく)が消費者を格納していると思います。

これはツール間で一貫した問題であるため、カフカに何かが正しく設定されていないのでしょうか、それとも0.9.xを完全にサポートしていないツールなのでしょうか?

+0

カフカオフセットのより新しいバージョンでは、スケーラビリティ上の理由から、カフカのオフセットが維持されています。トピック '__consumer_offsets 'は、この目的のために使用されます。 – Sebastian

答えて

0

カフカ0.9では、古いコマンドラインユーティリティConsumerOffsetCheckerを置き換えユーティリティkafka-consumer-groups.shを試すことができます。それは消費者の相殺情報を提供すべきである。

カフカ0.9では、zookeeperの代わりにオフセットを格納するために、デフォルトのトピック__consumer_offsetsがあります。古いバージョンでは、offsets.storageコンシューマプロパティを使用して、コンシューマオフセットを格納するためにコンシューマを使用するか、コンシューマオフセットを格納するかを制御することができます。 zookeeperは並行書き込みに最適化されていないため、kafkaが優先されます。

関連する問題