实验室3台机器：34,35,36
1、下载kafka安装包
到官网 http://kafka.apache.org/下载安装包kafka_2.12-1.1.0.tgz
2、解压到36服务器
1 cd /utxt/soft/qydx 2 tar -zxvf kafka_2.12-1.1.0.tgz
3、修改配置文件
1 cd kafka_2.12-1.1.0/config 2 vi server.properties
要修改的内容改为如下
1 broker.id=0
2 host.name=192.168.150.36
3 port=9097
4 advertised.host.name=192.168.150.36
5
6 delete.topic.enable=true
7 advertised.listeners=PLAINTEXT://192.168.150.36:9097
8 log.dirs=/utxt/soft/qydx/kafka_2.12-1.1.0/kafka-logs 9 num.partitions=10
10 # zookeeper集群的ip端口 11 zookeeper.connect=192.168.150.34:4181,192.168.150.35:4181,192.168.150.36:4181
12 zookeeper.connection.timeout.ms=100000
13 default.replication.factor=2
14 auto.create.topics.enable=true
如下图所示：
4、将kafka_2.12-1.1.0文件夹复制到另外两台节点下
1 scp -r kafka_2.12-1.1.0 @192.168.150.35:/utxt/soft/qydx/
2 scp -r kafka_2.12-1.1.0 @192.168.150.34:/utxt/soft/qydx/
并修改每个节点对应的server.properties文件的broker.id和listenrs
35:
broker.id=1
advertised.listeners=PLAINTEXT://192.168.150.35:9097
34:
broker.id=2
advertised.listeners=PLAINTEXT://192.168.150.34:9097
5、启动kafka集群
#1 必须先启动zookeeper集群.
#2 启动kafka集群
1 192.168.150.35
2
3 /utxt/soft/qydx/kafka_2.12-1.1.0/bin/kafka-server-start.sh -daemon /utxt/soft/qydx/kafka_2.12-1.1.0/config/server.properties 4
5
6 192.168.150.36
7
8 /utxt/soft/qydx/kafka_2.12-1.1.0/bin/kafka-server-start.sh -daemon /utxt/soft/qydx/kafka_2.12-1.1.0/config/server.properties 9
10
11 192.168.150.34
12
13 /utxt/soft/qydx/kafka_2.12-1.1.0/bin/kafka-server-start.sh -daemon /utxt/soft/qydx/kafka_2.12-1.1.0/config/server.properties