zookeepr+kafka叢集搭建(二)

zookeeper+kafka叢集安裝之二

此為上一篇文章的續篇, kafka安裝需要依賴zookeeper, 本文與上一篇文章都是真正分布式安裝配置, 可以直接用于生産環境.

zookeeper安裝參考:

一個僞代碼的實作如下:

$ wget http://apache.fayea.com/apache-mirror/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz

http://blog.csdn.net/ubuntu64fan/article/details/26678877

2)配置$KAFKA_HOME/config/server.properties

我們安裝3個broker，分别在3個vm上：zk1，zk2，zk3:

zk1:

$ vi /etc/sysconfig/network

$ vi $KAFKA_HOME/config/server.properties

zk2:

zk3:

3)啟動zookeeper服務, 在zk1,zk2,zk3上分别運作：

$ zkServer.sh start

$ kafka-server-start.sh $KAFKA_HOME/config/server.properties

$ kafka-topics.sh --create --topic test --replication-factor 3 --partitions 2 --zookeeper zk1:2181

$ kafka-console-producer.sh --broker-list zk1:9092 --sync --topic test

在發送消息的終端輸入：Hello Kafka

7)假設我們在zk3上，開一個終端，顯示消息的消費（zk3模拟consumer）

$ kafka-console-consumer.sh --zookeeper zk1:2181 --topic test --from-beginning

8) 程式設計操作Producer和Consumer的例子參考：