创建Topic
$ bin/kafka-topics.sh \
--create --topic test \
--replication-factor 2 \
--partitions 4 \
--zookeeper dpnode03:2181,dpnode04:2181,dpnode05:2181
这里创建了一个test消息队列，副本为2，分区为4。
查看Topic属性
$ bin/kafka-topics.sh \
--zookeeper dpnode03:2181,dpnode04,dpnode05 \
--describe --topic test
Topic：消息名称
Partition：分区号。下标从0开始。
Leader：所在分区的broker编号，负责处理消息的读写。
leader是从所有节点中随机选择的。
Replicas：列出了所有的副本节点，不管节点是否在服务中。
Isr：正在服务中的节点。
发送消息
$ bin/kafka-console-producer.sh \
--broker-list dpnode05:6667 \
--topic test
输入一行内容按回车
消费消息
$ bin/kafka-console-consumer.sh \
--zookeeper dpnode03,dpnode04,dpnode05:2181 \
--topic test \
--from-beginning
列举所有Topic
$ bin/kafka-topics.sh \
--zookeeper dpnode03:2181,dpnode04:2181,dpnode05:2181 \
--list
删除Topic
$ bin/kafka-topics.sh \
--zookeeper dpnode03:2181,dpnode04:2181,dpnode05:2181 \
--delete --topic test
