kafka的消费组处理(消费回滚处理)

查看消费者列表--list
bin/kafka-consumer-groups.sh --bootstrap-server 172.26.84.174:9092 --list

pindou_device_control
pindou_gc_pro
pindou_garbagecollection_1
pindou_garbagecollection_revice

查看指定消费组详情--group
bin/kafka-consumer-groups.sh --bootstrap-server 172.26.84.174:9092 --describe --group pindou_gc_pro
bin/kafka-consumer-groups.sh --bootstrap-server 172.26.84.174:9092 --describe --group pindou_csp_pro

所有消费组成员信息
bin/kafka-consumer-groups.sh --describe --all-groups --members --bootstrap-server 172.26.84.174:9092

指定消费组成员信息
bin/kafka-consumer-groups.sh --describe --members --group pindou_gc_pro --bootstrap-server 172.26.84.174:9092

所有消费组状态信息
bin/kafka-consumer-groups.sh --describe --all-groups --state --bootstrap-server 172.26.84.174:9092

指定消费组状态信息
bin/kafka-consumer-groups.sh --describe --state --group pindou_gc_pro --bootstrap-server 172.26.84.174:9092

删除指定消费组--group
sh bin/kafka-consumer-groups.sh --delete --group test2_consumer_group --bootstrap-server xxxx:9090
删除所有消费组--all-groups
sh bin/kafka-consumer-groups.sh --delete --all-groups --bootstrap-server xxxx:9090

重置指定消费组的所有Topic的偏移量--all-topic
sh bin/kafka-consumer-groups.sh --reset-offsets --to-earliest --group test2_consumer_group --bootstrap-server xxxx:9090 --dry-run --all-topic
重置指定消费组的指定Topic的偏移量--topic
sh bin/kafka-consumer-groups.sh --reset-offsets --to-earliest --group test2_consumer_group --bootstrap-server xxxx:9090 --dry-run --topic test2

重置所有消费组的所有Topic的偏移量--all-topic
sh bin/kafka-consumer-groups.sh --reset-offsets --to-earliest --all-group --bootstrap-server xxxx:9090 --dry-run --all-topic
重置所有消费组中指定Topic的偏移量--topic
sh bin/kafka-consumer-groups.sh --reset-offsets --to-earliest --all-group --bootstrap-server xxxx:9090 --dry-run --topic test2

--to-earliest : 重置offset到最开始的那条offset(找到还未被删除最早的那个offset)
--to-current: 直接重置offset到当前的offset，也就是LOE
--to-latest： 重置到最后一个offset
--to-datetime: 重置到指定时间的offset;格式为:YYYY-MM-DDTHH:mm:SS.sss; --to-datetime "2021-6-26T00:00:00.000"
--to-offset 重置到指定的offset,但是通常情况下,匹配到多个分区,这里是将匹配到的所有分区都重置到这一个值; 如果 1.目标最大offset<--to-offset, 这个时候重置为目标最大offset；2.目标最小offset>--to-offset ，则重置为最小; 3.否则的话才会重置为--to-offset的目标值; 一般不用这个 --to-offset 3465
--shift-by 按照偏移量增加或者减少多少个offset；正的为往前增加;负的往后退；当然这里也是匹配所有的; --shift-by 100 、--shift-by -100
--from-file 根据CVS文档来重置; 这里下面单独讲解