查看topic列表: ./kafka-topics.sh --list --zookeeper 10.10.94.151:2181|grep wu
查看topic详情: ./kafka-topics.sh --describe --zookeeper 10.10.94.151:2181|grep wu
创建topic: ./kafka-topics.sh --create --topic mytopic1 --zookeeper localhost:2181 --partitions 1 --replication-factor 1 --config xxx
删除topic: ./kafka-topics.sh --delete --topic mytopic1 --zookeeper localhost:2181
修改topic: ./kafka-topics.sh --alter --topic mytopic1 --zookeeper localhost:2181 --partitions 5

查看consumer组内消费的offset：
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper tsp03:2181 --group rtm_statistics_lt29s --topic statistics_lt_20190724
生产者客户端（向kafka生产一条消息）
./kafka-console-producer.sh --broker-list 10.10.94.151:6667,10.10.94.152:6667,10.10.94.153:6667 --topic storm_fault_event
消费者客户端（从kafka消费一条消息）
./kafka-console-consumer.sh --zookeeper 10.10.94.151:2181,10.10.94.152:2181,10.10.94.153:2181 --from-beginning --topic storm_fault_event