kafak基本操作

标签：基本   list   strong   font   roc   span   console   cer   create   

创建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基本操作

标签：基本   list   strong   font   roc   span   console   cer   create   

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