Kafka：重置主题特定分区的偏移量

【问题标题】：Kafka : Reset offset of a specific partition of topicKafka：重置主题特定分区的偏移量
【发布时间】：2019-07-20 05:50:01
【问题描述】：

我正在尝试重置 kafka 主题的特定分区的偏移量，但我没有找到任何命令。

我是能够使用以下命令重置主题的所有分区的偏移量，但我只想重置特定分区的偏移量。

适用于所有分区的命令

kafka-consumer-groups.sh -- bootstap-server localhost:1111 -- command-config <file> -- group <group> -- topic <topic> -- reset-offset -- shift-by -1

上述命令不接受分区，并为所有分区重置。我怎样才能只重置特定的分区。

【问题讨论】：

【解决方案1】：

要仅更改特定分区的偏移量，您必须传递 --topic 标志、主题名称和要修改的分区号。

可以使用以下命令：

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:1111 --group grId --topic someTopicName:0 --reset-offsets --shift-by 1 --execute

来自kafka-consumer.groups.sh 的摘要可能会帮助您更好地理解它：

--topic ：消费组的topic 信息应被删除或应该包含的主题复位偏移过程。在reset-offsets 的情况下，分区可以是使用此格式指定：topic1:0,1,2，其中 0,1,2 是要包含在进程中的分区。重置偏移量还支持多个主题输入。

【讨论】：