linux 单机安装 kafka，个人练习的时候是非常方便的

安装 kafka 前需要先安装 java 的环境，这里对 java 的版本和 kafka 的版本有要求。kafka 使用Scala 语言开发，因此在下载 kafka 时，需要看其使用的 Scala 的版本及对应的 java 版本是否一致，避免出现版本问题

笔者这里使用的 java 版本是 java8，因此使用 kafka 的版本是 kafka_2.12-2.8.1.tgz，Scala 的版本和 kafka 的版本可以在 kafa 官网看到

目录

1、官网下载 kafka

2、安装 kafka

3、启动 kafka

4、测试

---

1、官网下载 kafka

https://kafka.apache.org/kafka官网：

选择适合已安装 java 环境的 kafka 版本

笔者是 java8 的环境，选择的 kafka 的版本是 kafka_2.12-2.8.1.tgz

2、安装 kafka

将下载的 kafka 安装包上传到 linux

 创建 kafka 安装目录

mkdir /usr/local/kafka

 将 kafka 安装包解压到新创建的 kafka 目录

tar -xzf kafka_2.12-2.8.1.tgz -C /usr/local/kafka

 进入 kafka 安装目录

cd /usr/local/kafka/kafka_2.12-2.8.1/

 进入 config 目录，编辑 server.properties 文件

cd config

编辑  server.properties 文件

 vi server.properties

将 listeners 和 advertised.listeners 地址修改为当前机器 ip 地址（笔者当前机器 ip 地址是192.168.0.124），端口默认9092

然后修改 zookeeper 地址，笔者这里 zookeeper 的地址是 192.168.0.111:2181，读者可根据自己的情况修改

server.properties 文件编辑完成后，开放放火墙端口 9092

查看防火墙所有开放的端口：

firewall-cmd --list-port

开放防火墙端口 9092

firewall-cmd --zone=public --add-port=9092/tcp --permanent

更新防火墙规则（无需断开连接，动态添加规则）

firewall-cmd --reload

 

3、启动 kafka

启动 kafka 前需要先启动 zookeeper

没安装 zookeeper 的朋友可以先看这2篇文章

windows 环境 安装 zookeeper：https://blog.csdn.net/wsjzzcbq/article/details/88301892 

linux 环境 安装 zookeeper：https://blog.csdn.net/wsjzzcbq/article/details/88310571

zookeeper 启动成功后，启动 kafka

启动 kafka 命令

bin/kafka-server-start.sh config/server.properties &

 停止 kafka

bin/kafka-server-stop.sh

4、测试

启动 kafka 后，打开2个终端连接 linux，然后分别进入 kafka 安装目录 

cd /usr/local/kafka/kafka_2.12-2.8.1/

 开启消费者监听消息

bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.124:9092 --topic demo-topic --from-beginning

打开生产者发送消息

bin/kafka-console-producer.sh --broker-list 192.168.0.124:9092 --topic demo-topic

效果图

至此完