Skip to content

Kafka偏移推进

进入Kafka安装目录。

执行以下命令:

bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --group 消费组名 --reset-offsets --topic babj_bfdb.usr_sod.tabname:0 --to-offset 具体偏移 --execute