我试图重置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是要包含在进程中的分区。重置偏移量还支持多个主题输入。