實驗室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