apache-kafka - 卡夫卡 : Reset offset of a specific partition of topic

Question

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

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

适用于所有分区的命令

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

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

Answer 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 : The topic whose consumer group information should be deleted or topic whose should be included in the reset offset process. In reset-offsets case, partitions can be specified using this format: topic1:0,1,2, where 0,1,2 are the partition to be included in the process. Reset-offsets also supports multiple topic inputs.