我试图重置Kafka主题的特定分区的偏移量,但没有找到任何命令。
我可以使用下面的命令重置一个主题的所有分区的偏移量,但是我只想重置一个特定分区的偏移量。
适用于所有分区的命令
kafka-consumer-groups.sh -- bootstap-server localhost:1111 -- command-config <file> -- group <group> -- topic <topic> -- reset-offset -- shift-by -1
上面的命令不接受分区,并重置所有分区。如何只重置特定分区。
1条答案
按热度按时间bis0qfac1#
要仅更改特定分区的偏移量,必须传递
--topic
要修改的标志、主题名和分区号。可以使用以下命令:
来自的摘要
kafka-consumer.groups.sh
可能有助于您更好地理解:--主题:应删除其消费群体信息或应将其包含在重置偏移过程中的主题。在
reset-offsets
在这种情况下,可以使用以下格式指定分区:topic1:0,1,2
,其中0、1、2是要包含在进程中的分区。重置偏移量还支持多个主题输入。