1. 建立主題 

在客戶端就可以建立

指定主題名字topic1，指定partition 副本數為3（不能超過叢集節點數），指定分割槽數目 4 ，指定zk節點

./kafka-topics.sh --create --topic topic1 --replication-factor 3 --partitions 4 --zookeeper 10.10.100.215:2181

Created topic "topic1".

建立了4個分割槽

2.檢視主題

[[email protected] bin]# ./kafka-topics.sh --list --zookeeper 10.10.100.215 2181
topic1
 

3.啟動消費者

 消費者會一直組塞著

./kafka-console-consumer.sh --zookeeper 10.10.100.215:2181 --topic topic1

4.啟動生產者

指定215、216、217 任何一個broker 都可以。注意埠是9092

./kafka-console-producer.sh --broker-list 10.10.100.216:9092 --topic topic1

  輸入資料即可，消費者可以監聽到