（本文中 zookeeper:2181 和kafka 9092 的 的zookeeper 和kafka 对应的是你对应服务的IP地址，
本文的kafka的版本是0.10.0.0）
首先进到kafka 的容器中 找到bin目录，我们可以看到有很多脚本文件
kafka 脚本
创建一个主题
sh kafka-topics.sh --create --zookeeper zookeeper :2181 --replication-factor 1 --partitions 1 --topic test
查看主题
sh kafka-topics.sh --list --zookeeper zookeeper :2181
打开生产者界面
sh kafka-console-producer.sh --broker-list kafka:9092 --topic test
打开消费者界面
消费者记录在zookeeper
sh kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic test --from-beginning
消费者记录在kafka
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic
test2 --from-beginning --new-consumer
查询消息消费情况
如果消费者记录在kafka 可以这样查看消费者的分组情况
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --list --new-consumer
执行之后可以看到分组的groupId 例如 console-consumer-20764
查看消费情况
kafka-consumer-groups.sh --new-consumer --bootstrap-server kafka:9092 --group console-consumer-20764 --describe
如果消费记录在zookeeper 可以这样可查看分组
kafka-consumer-groups.sh --zookeeper zookeeper:2181 --list
执行之后可以看到分组的gruopId 例如 console-consumer-25338
查看消费情况
kafka-consumer-groups.sh --zookeeper zookeeper:2181 --group console-consumer-25338 --describe
删除主题
sh kafka-topics.sh --delete --zookeeper zookeeper:2181 --topic test
这个命令只能标记这个topic 被删除，通过查看主题的命令还可以看到该主题。
查看kafka 消息文件所在目录 /kafka/config/server.properties
找到 log.dirs
我的文件对于的地址是 log.dirs=/tmp/kafka-logs
到这个目录下可以看到kafka 存在磁盘的文件
