首页 文章

Kafka 0.11如何重置偏移量

提问于
浏览 次
20

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

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

任何人都可以在非动物园管理员经纪人中重置消费者抵消 .

apache-kafka

1 回答

  • 41

    默认情况下， --reset-offsets 只打印操作的结果 . 要实际执行操作，您需要将 --execute 添加到您的命令：

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

相关问题