查看

1. 查看topic列表

./kafka-topics.sh --bootstrap-server 0.0.0.0:9092 --list 

2. 查看消费组列表

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

3. 查看消费组有无数据

./kafka-console-consumer.sh --bootstrap-server  0.0.0.0:9092 --topic tocpi名 --from-beginning    
# 若没有任何返回或没有响应，则该topic中没有数据内容；否则就是有数据  --from-beginning

4. 查看 lga偏移量

./kafka-consumer-groups.sh --bootstrap-server 0.0.0.0:9092 --group 消费组名  --describe 
##  --describe 从历史数据开始查看

5. 消除lga堆积偏移量

./kafka-consumer-groups.sh --bootstrap-server 0.0.0.0:9092 --group 消费组名   --reset-offsets --all-topics --to-latest --execute

6. 添加 partitions消费分区数

kafka-topics.sh --alter --partitions 3 --topic  topic名   --bootstrap-server 0.0.0.0:9092