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=0
host.name=master

为

broker.id=1
host.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 集群已经搭建成功。