在公司的项目中需要用到kafka和c#进行消息发送，有一天不知道为啥，下端就出现一直读取消息的问题，所以得清空通道内的消息

1.docker ps 获取到当前kafka的容器id：【673e6f1401c7】

docker ps -a 可以查看所有容器，docker stats，查看吞吐量 

du -sh，统计当前目录占用空间，df -h 查看磁盘空间。

2.进入kafka对应的容器内部

docker exec -it 673e6f1401c7 bash

3.查看全部的topic

cd  /opt/kafka_2.12-2.4.0/bin

kafka-topics.sh -list --zookeeper localhost:2181

4.重头查看kafka topic下的消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --from-beginning

5.按照偏移量查看kafka topic下的消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --offset latest --partition 0 # --offset 

设置偏移量 latest代表最后 ，可以设置区间，不设置结尾的话默认为查询到latest(最后) # --partition 设置分区 使用偏移量查询时一定要设置分区才能查询

删除kafka下topic
kafka-topics.sh  --delete --zookeeper 【zookeeper server】  --topic 【topic name】