kafka查询命令---Linux

kafka版本：kafka_2.12-2.1.1

kafka_port默认9092，zk_port默认2181

查看topic

bin/kafka-topics.sh --zookeeper zk_ip:zk_port --list

查看group

bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --list

查看topic下group的消费情况

bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --group group_name --describe

⼿动设置offset

停⽌consumer后，设置group=3，topic=test的offset为1524510

bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --group 3 --topic test --execute --reset-offsets --to-offset 1524510