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