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