在公司的项目中需要用到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】
