环境
Ubuntu 16.04
java环境
zookeeper真集群安装好（奇数）
机器一 : 192.168.0.166
机器二：192.168.0.169
机器三：192.168.0.170
机器一操作
下载
官网下载地址：下载地址
root@paa2:~# wget http://apache.claz.org/kafka/2.1.0/kafka_2.11-2.1.0.tgz
root@paa2:~# tar xf kafka_2.11-2.1.0.tgz -C /usr/local/
root@paa2:~# mv /usr/local/kafka_2.11-2.1.0 /usr/local/kafka
配置文件
root@paa2:/usr/local/kafka/config# vim server.properties
···
broker.id=1 #默认是0，这里自定义
host.name=192.168.0.166 #ip地址
zookeeper.connect=192.168.0.169:2181,192.168.0.170:2181,192.168.0.166:2181 #zookeeper集群地址
···
其余2台
同样的操作在server-2和server-3上修改一下broker.id和host.name
# scp -r /usr/local/kafka root@192.168.0.170:/usr/local/
# scp -r /usr/local/kafka root@192.168.0.170:/usr/local/
启动
root@paa2:/usr/local/kafka/bin# ./kafka-server-start.sh -daemon ../config/server.properties
三台机器 都开启
注意的问题是 host.name不要错
关闭
不需要任何参数
root@paa2:/usr/local/kafka/bin# ./kafka-server-stop.sh
连接zookeeper测试
[zk: localhost:2181(CONNECTED) 0] ls /
[cluster, controller_epoch, controller, brokers, zookeeper, admin, isr_change_notification, consumers, log_dir_event_notification, latest_producer_id_block, config]
[zk: localhost:2181(CONNECTED) 1] ls /brokers
[ids, topics, seqid]
[zk: localhost:2181(CONNECTED) 2] ls /brokers/ids
[1, 2, 3]
[zk: localhost:2181(CONNECTED) 3]
说明：
zookeeper集群建好之后，通过“ls /”出来的只有zookeeper，连接kafka使用后，/ 下面多了不少东西，其中通过查看/brokers/ids可以发现已经检查到了已经安装的三台kafka的broker.id[1,2,3]。