2017-08-14 79 views
15

私はKafkaの最新のCLIツールでコンシューマオフセットをリセットしようとしています。Kafka 0.11オフセットをリセットする方法

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --reset-offsets --to-earliest --all-topics 

その結果、私はこの出力を参照してください。

TOPIC       PARTITION NEW-OFFSET 
FirstTopic      0   0 
SecondTopic      0   0 

しかし、再び実行するには、コマンド:出力の

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --describe 

結果:

Consumer group 'my-group' has no active members. 

TOPIC    PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG 
FirstTopic   0   1230   1230   0 
SecondTopic  0   1022   1022   0 

を私は他の試してみました明示的なオフセットまたはspにリセットするようなオプショントピックを直接的にエコ化しますが、結果は同じです。出力は、コマンドが記述されているオフセットをチェックしている間に操作が成功したことを示唆しているか、またはデバッグではオフセットが変更されていないことを示しています。

誰も、飼い猫以外のブローカー内で消費者オフセットをリセットすることに成功します。

答えて

21

デフォルトでは、--reset-offsetsは操作の結果を出力します。実際に操作を実行するには、コマンドに--executeを追加する必要があります。

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group 
my-group --reset-offsets --to-earliest --all-topics --execute 
+0

私の男。私もヘルプ出力から--executeを逃しました。メーリングリストとbugtrackerを使ってこの機能が壊れているかどうかを調べていました。 – RedShift

+0

私も、--executeフラグを忘れてしまいます。このQAをありがとうございます。 – Bruce

関連する問題