kafka真集群安装

/ Linux服务安装搭建 / 没有评论 / 965浏览

环境

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]。