kafka命令之消费者组

kafka命令-消费者组相关查询及设置

查看消费者组

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

查看具体消费者组信息【partition、offset、lag、host等】

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group ${group_name}

设置具体消费者组下topic offset

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --execute --reset-offsets --to-latest --group ${consumer_group_name} --topic ${topic_name}

offset部分重设策略

–to-earliest：把位移调整到分区当前最小位移
–to-latest：把位移调整到分区当前最新位移
–to-current：把位移调整到分区当前位移
–to-offset ： 把位移调整到指定位移处
–shift-by N： 把位移调整到当前位移 + N处，注意N可以是负数，表示向前移动
–to-datetime ：把位移调整到大于给定时间的最早位移处，datetime格式是yyyy-MM-ddTHH:mm:ss.xxx
–by-duration ：把位移调整到距离当前时间指定间隔的位移处，duration格式是PnDTnHnMnS
–from-file ：从CSV文件中读取调整策略