卡夫卡0.11如何重置偏移量

Question

我正在嘗試用卡夫卡最新的CLI工具重置消費者偏移量。

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直接指出主題但結果相同。輸出表明操作成功，同時使用describe命令檢查偏移量或調試顯示偏移量未更改。

任何人都可以重置非zookeeper代理中的消費者偏移。

Answer 1

默認情況下，--reset-offsets只是打印操作的結果。要真正執行操作，您需要將--execute添加到您的命令中：

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