1.创建topic
sh kafka-topics.sh –zookeeper 1.1.1.1:2181 –create –topic galileo.event –partitions 8 –replication-factor 1
2.查看topics
./kafka-topics.sh –zookeeper 1.1.1.1:2181 –list
3.删除topic ./kafka-topics.sh –zookeeper 1.1.1.1:2181 –topic galileo.notify –delete
删除后，再查看 会显示maked be deleted，但是还没真正删除。 此时你若想真正删除它，可以如下操作： （1）登录zookeeper客户端：命令：./bin/zookeeper-client （2）找到topic所在的目录：ls /brokers/topics （3）找到要删除的topic，执行命令：rmr /brokers/topics/【topic name】即可，此时topic被彻底删除。
4.控制台生产数据 ./kafka-console-producer.sh –broker-list 1.1.1.1:9092 –topic ulogqa
5.控制台消费数据 ./kafka-console-consumer.sh –bootstrap-server 1.1.1.1.:9092 –topic ulogqa ./kafka-console-consumer.sh –bootstrap-server 1.1.1.1.:9092 –topic galileo.metrics
6.控制台查看topic被消费情况 sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker –group test1 –topic mcc_logs –zookeeper v1:2181
7.查看topic的partition及增加partition ./kafka-topics.sh –zookeeper 10.2.1.1:2181 –topic mcc-logs –describe (例如开了两个节点消费同一个topic、group，发现只有一个在打日志，另一个没动静也没挂。就该查一下是不是只分了一个partition)
