找了一圈,重置的命令都是下面2种,
bin/kafka-consumer-groups.sh --bootstrap-server BORKER_HOST1:PORT1,BORKER_HSOT2:PORT2 --group GROUP_NAME --reset-offsets --execute --to-offset NEW_OFFSET --topic TOPIC_NAME
bin/kafka-consumer-groups.sh --bootstrap-server BORKER_HOST1:PORT1,BORKER_HSOT2:PORT2 --group GROUP_NAME --reset-offsets --execute --to-earliest/--to-latest --topic TOPIC_NAME
但我用的版本(2.11-0.10.1.0)执行时报 “reset-offsets is not a recognized option”,“offset is not a recognized option”
在使用kafka-console-consumer.sh时倒是可以使用--offset
指定,但只能消费单个partition,不知道有没有其它可行的方法