Kafka指令重置偏移量

Posted 2023-03-02 无故事王国LH

#查看topic 列表
sh bin/kafka-consumer-groups.sh --bootstrap-server 172.24.140.181:9092,172.24.140.182:9092,172.24.140.183:9092 --list
#查看消费者信息
sh ./kafka-consumer-groups --bootstrap-server 172.24.140.181:9092,172.24.140.182:9092,172.24.140.183:9092 --describe --group API_SQLSERVER_GROUP
#重置消费offset
sh ./kafka-consumer-groups --reset-offsets --to-offset 596203816 --group API_SQLSERVER_GROUP --bootstrap-server 172.24.140.181:9092,172.24.140.182:9092,172.24.140.183:9092 --execute --topic Register

2、Error: Assignments can only be reset if the group ‘logstash_kafka_group’ is inactive, but the current state is Stable
简单的说就是，相同的 group 有其他的 topic 正在使用和消费，那么这个 group 是出于 active 状态。出于 active 状态的 group 的任何 topic 的 offset 是不能够被 reset 的。