kafka命令行:node
$ 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-beginningkafka
$ bin/kafka-topics.sh --zookeeper dpnode03:2181,dpnode04:2181,dpnode05 --listconsole
kafka-console-producer.bat --broker-list broker01.com:9092 --topic topic1test
kafka-console-consumer.sh --zookeeper dpnode03,dpnode04,dpnode05:2181 --topic test --consumer.config xx.configzookeeper