CentOS Kafka 2.5.0 单机集群安装（伪集群）

以安装路径/usr/local/soft，IP 192.168.44.161为例
实际上就是在同一台机器上，运行多个kafka服务，只是端口不同。

基于kafka单机版安装流程，先看一遍这个步骤：
CentOS安装kafka 2.5.0单机版

所有的kafka节点连接到相同的ZK（或ZK集群），需要先安装一个ZK。
ZK安装参考：
CentOS安装Zookeeper 3.6.1单节点
在本例中ZK也安装在这台机器上。

注意：
单机的kafka和集群的kafka不要混用一个zk，否则会出现数据混乱的问题。

1、下载解压kafka

cd /usr/local/soft
wget https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz
tar -xzvf kafka_2.13-2.5.0.tgz
cd kafka_2.13-2.5.0

2、修改配置文件

复制3个配置文件

cd config
cp server.properties server1.properties 
cp server.properties server2.properties 
cp server.properties server3.properties 

修改配置文件中的broker.id分别为1、2、3
listeners这一行取消注释，端口号分别为9093、9094、9095
log.dirs分别设置为kafka-logs1、kafka-logs2、kafka-logs3（先创建）

mkdir -p /tmp/kafka-logs1 /tmp/kafka-logs2 /tmp/kafka-logs3

server1.properties 的配置：

broker.id=1
listeners=PLAINTEXT://192.168.44.161:9093
log.dirs=/tmp/kafka-logs1

server2.properties 的配置：

broker.id=2
listeners=PLAINTEXT://192.168.44.161:9094
log.dirs=/tmp/kafka-logs2

server3.properties 的配置：

broker.id=3
listeners=PLAINTEXT://192.168.44.161:9095
log.dirs=/tmp/kafka-logs3

3、启动3个服务

第一步：
启动ZK。

再启动kafka。

cd ../bin
./kafka-server-start.sh -daemon ../config/server1.properties
./kafka-server-start.sh -daemon ../config/server2.properties
./kafka-server-start.sh -daemon ../config/server3.properties

PS：如果遇到zk node exists的问题，先把brokers节点删掉（临时解决方案）。

4、集群下创建Topic

在bin目录下，
创建一个名为gptest的topic，只有一个副本，一个分区：

sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic gptest

查看已经创建的 topic：

sh kafka-topics.sh -list -zookeeper localhost:2181

5、集群下启动Consumer

在一个新的远程窗口中：

sh kafka-console-consumer.sh --bootstrap-server 192.168.44.161:9093,192.168.44.161:9094,192.168.44.161:9095 --topic gptest --from-beginning

6、集群下启动Producer

打开一个新的窗口，在kafka解压目录下：

sh kafka-console-producer.sh --broker-list 192.168.44.161:9093,192.168.44.161:9094,192.168.44.161:9095 --topic gptest

7、集群下Producer窗口发送消息

在生产者窗口输入hello world 回车