2017-07-12 14 views

答えて

0

これはコンシューマグループごとに行うことができます。あなたは消費者オフセットチェッカーツール使用してトピックの試みでフィルタリングする場合:

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker

をまた(それが現在のトピックのフィルタリングを提供していません)推奨コンシューマ・グループのコマンドを使用することができます。

bin/kafka-consumer-groups.sh

参考文献:herehere

+0

トピックフィルターはbin/kafka-consumer-groups.shの0.11バージョンに含まれています –

+0

@ HansJespersen最新バージョンには '--topic'オプションがありますが、削除やリセットにのみ使用できますオフセットを記述するためのものではありません(上記の質問におそらく役立つオプション)。 – vahid

+0

合意済み@vahid。私はあなたが--executeオプションを省略することができ、実行せずに現在のデータとリセットプランを出力すると考えました。これでうまくいかない場合は、bin/kafka-topics.sh --listとbin/kafka-topics.sh --describeとconsumer-groups.shの組み合わせを使用してすべてのデータを取得する必要があります –

関連する問題