1创建topic

在/opt/cloudera/parcels/CDH/lib/kafka/bin目录下：

./kafka-topics.sh --create --zookeeper cdh03:2181 --replication-factor 2 --partitions 3 --topic test

2查看指定topic

./kafka-topics.sh --describe --zookeeper cdh03:2181 --topic test

从上图看出，  topic有3个分区， 2个副本。  

       每分区的所有副本都只有一个leader , 由该lead broker进行读写分区数据。

3 查看所有topic

./kafka-topics.sh --list --zookeeper cdh03:2181

4 删除topic

./kafka-topics.sh --delete --zookeeper cdh03:2181 --topic test

5 控制台发送消息

./kafka-console-producer.sh --broker-list cdh03:9092 --topic test

6 控制台消费消息

./kafka-console-consumer.sh --bootstrap-server cdh03:9092 --topic test   --from-beginning

15 查看kafka分区信息： get /brokers/topics/[topic]/partitions/[partition]/state

16 查看kafka controller:   get /controller

17 查看kafka偏移量

 get /consumers/[groupId]/offsets/[topic]/[partitionId]