kafka命令

./kafka-topics.sh --zookeeper ip:port --list

./kafka-topics.sh --create --topic test --zookeeper ip:port --replication-factor 1 --partitions 1

./kafka-console-producer.sh --broker-list ip:port --topic test

/kafka-console-consumer.sh --zookeeper ip:port --topic test --from-beginning

kafka document:

http://kafka.apache.org/documentation.html#theconsumer