首页 文章

kafka 0.11按 - 日期时间重置消费者组的偏移量

提问于
浏览 次
3

我想通过时间戳重置kafka使用者组的偏移量 . 但是当我使用以下命令时：

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --to-datetime 2017-11-1907:52:43:00:000 --group <group_name> --topic <topic_name> --execute

我收到以下错误消息：

注意：这仅显示有关使用Java使用者API的消费者的信息（非基于ZooKeeper的使用者） .

如何根据时间重置偏移量

apache-kafka kafka-consumer-api

2 回答

  • 2

    这不是错误，而是一个警告 - 因为您指定了 --bootstrap-server 选项，然后更改将仅影响使用新Java API实现的使用者 . 如果您有使用其他API构建的使用者，则需要指定 --zookeeper 选项 .

    回复于
  • 1

    调用

    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092
--group test-group --reset-offsets --all-topics --to-datetime 2017-08-04T00:00:00.000

    可以在给定的日期时间之后将偏移重置为最早的偏移量 . 例如，日期时间格式为 yyyy-MM-ddTHH:mm:ss.xxx ，2017-08-04T00：00：00.000 .

    您还可以按持续时间重置偏移量 . 请参阅以下示例：

    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 
--group test-group --reset-offsets --all-topics --by-duration PT0H30M0S

    --by-duration 将偏移量重置为与当前时间戳的持续时间相抵消 . 格式：'PnDTnHnMnS' .

    回复于

相关问题