apache-kafka - Kafka 0.11 如何重置偏移量

Question

我正在尝试使用最新的 Kafka 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

我尝试了其他选项，例如重置为显式偏移或直接指定主题，但结果相同。输出表明操作成功，同时使用描述命令检查偏移或调试显示偏移未更改。

任何人都可以在非 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