kafak基本操作

创建topic

bin/kafka-topics.sh --create --zookeeper 192.168.1.81:2181 --replication-factor 3 -partitions 10 --topic RecordPreprocessingTest1

##控制台发送消息

bin/kafka-console-producer.sh --broker-list 192.168.1.81:9092 --topic RecordPreprocessingTest1

#控制台接收消息

bin/kafka-console-consumer.sh --zookeeper 192.168.1.83:2181 --from-beginning --topic RecordPreprocessingTest1

kafak基本操作

原文：http://www.cnblogs.com/xyniu/p/7423435.html