kafka命令列：

$ bin/kafka-console-producer.sh --broker-list dpnode05:6667 --topic "testThis is the first message"

$ bin/kafka-console-consumer.sh --zookeeper dpnode03,dpnode04,dpnode05:2181 --topic test  --from-beginning

$ bin/kafka-topics.sh --zookeeper dpnode03:2181,dpnode04:2181,dpnode05 --list

kafka-console-producer.bat --broker-list broker01.com:9092 --topic  topic1

kafka-console-consumer.sh --zookeeper dpnode03,dpnode04,dpnode05:2181 --topic test  --consumer.config xx.config