2017-06-29 6 views
1

私はKafka 0.10を使用していますが、私は/ binディレクトリに用意されているツールがあるかどうかを知りたいのですが、の特定の位置に消費者のオフセットを変更することができますか?Kafka:オフセットを特定の位置に変更するスクリプトユーティリティはありますか?

私はJava API(seek(...)メソッドを使用していますが、私はコマンドラインからその方法を見つけることができません。

答えて

2

0.11は

あなたはカフカ - 消費者グループは--reset-オフセットオプション

でコマンドを使用する場合、このリセット機能にちょうど出て、コメントを追加しました