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
修改
zookeeper.connect=localhost:2181
为
zookeeper.connect=master:2181,slave:2181
添加
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 集群已经搭建成功。