CentOS 6.7安裝Kafka 0.10.1

CentOS 6.7安裝Kafka 0.10.1

master

[root@master ~]# wget http://apache.fayea.com/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz[root@master ~]# tar -zxvf kafka_2.10-0.10.1.0.tgz[root@master ~]# mv kafka_2.10-0.10.1.0 /usr/local/

[root@master ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties

1. 修改

   zookeeper.connect=localhost:2181

   為

   zookeeper.connect=master:2181,slave:2181

2. 添加

   host.name=master

保存退出

[root@master ~]# rsync -av /usr/local/kafka_2.10-0.10.1.0 slave:/usr/local/

slave

[root@slave ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties

修改

broker.id=0host.name=master

為

broker.id=1host.name=slave

保存退出

啟動Kafka

master

[root@master ~]# cd /usr/local/kafka_2.10-0.10.1.0/[root@master kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties

slave

[root@slave ~]# cd /usr/local/kafka_2.10-0.10.1.0/[root@slave kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties

• 最後，檢驗是否安裝成功。使用 Kafka 自帶的客戶端檢測。進入 Kafka 安裝主目錄，先啟動生產者進入交互客戶端模式

master

創建一個名為 test 的主題

[root@master kafka_2.10-0.10.1.0]# bin/kafka-topics.sh --create --zookeeper master:2181 --replication-factor 1 --partitions 1 --topic test

在一個終端上啟動一個生產者

[root@master kafka_2.10-0.10.1.0]# bin/kafka-console-producer.sh --broker-list master:9092 --topic test

slave

在另一個終端中啟動消費者，進入交互客戶端

[root@slave kafka_2.10-0.10.1.0]# bin/kafka-console-consumer.sh --zookeeper master:2181 --topic test --from-beginning

在master（生產者）上，鍵盤輸入Hello World!；之後在slave（消費者）上，屏幕有同樣的信息輸出。證明 Kafka 集群已經搭建成功。