消息中间件
kafka

kafka-搭建Kafka集群

每台主机都需要安装jdk 本文版本jdk-1.8.0_231

需要搭建好的zookeeper集群

本文zookeeper环境：192.168.2.112:2181,192.168.2.113:2181,192.168.2.114:2181

本文将Kafka搭建在部署zookeeper集群的三台主机上，当然也可以另外准备三台主机。

在每台主机上执行下面步骤：

1
2
3
4
5
6
7
8
9
10
11
12
13
#将安装包移到/usr/local目录下
mv kafka_2.11-2.0.0 .tgz /usr/local
#解压文件
tar -zxvf kafka_2.11-2.0.0 .tgz
#重命名文件夹为kafka
mv kafka_2.11-2.0.0 kafka
#配置kafka环境变量，首先打开profile文件
vim /etc/profile
#进入编辑模式，在文件末尾添加kafka环境变量
export KAFKA_HOME=/usr/local/apache/kafka
PATH=${KAFKA_HOME}/bin:$PATH
#保存文件后，让该环境变量生效
source /etc/profile

node-1修改server.properties配置文件

打开配置文件

1
vim /usr/local/apache/kafka/config/server.properties

修改配置如下

1
2
3
broker.id=0
listeners=PLAINTEXT://192.168.2.112:9092
zookeeper.connect=192.168.2.112:2181,192.168.2.113:2181,192.168.2.114:2181

node-2修改server.properties配置文件

修改配置如下

1
2
3
broker.id=1
listeners=PLAINTEXT://192.168.2.113:9092
zookeeper.connect=192.168.2.112:2181,192.168.2.113:2181,192.168.2.114:2181

node-3修改server.properties配置文件

修改配置如下

1
2
3
broker.id=2
listeners=PLAINTEXT://192.168.2.114:9092
zookeeper.connect=192.168.2.112:2181,192.168.2.113:2181,192.168.2.114:2181

启动Kafka

要确保zookeeper节点已全部启动

在每台主机上分别启动Kafka

1
2
cd $KAFKA_HOME
bin/kafka-server-start.sh -daemon config/server.properties

在其中一台虚拟机创建topic ，参数zookeeper可以填写任意主机

1
/bin/kafka-topics.sh --create --zookeeper 192.168.2.112:2181 --replication-factor 3 --partitions 1 --topic test-topic

查看创建的topic信息，参数zookeeper可以填写任意主机

1
/bin/kafka-topics.sh --describe --zookeeper 192.168.2.114:2181 --topic test-topic