centos7安装kafka3.4

查看官网快速入门：https://kafka.apache.org/documentation.html#quickstart
通过快速入门可以明确，需要先安装Java环境，但centos7操作系统默认已安装；同时也可以了解到，kafka不仅可以搭配ZooKeeper使用，还可以搭配Kraft

查看java版本，如下：

本操作系统已有符号要求的java环境，故此略过java安装和更新。

一、安装

1.1 下载kafka最新版本

官网：http://kafka.apache.org/downloads
镜像：https://mirrors.bfsu.edu.cn/apache/kafka/3.4.0/kafka_2.12-3.4.0.tgz --no-check-certificate

1.2 解压

解压命令：tar -zxvf kafka_2.12-3.4.0.tgz
创建日志目录：

cd /var/log
mkdir kafka
cd kafka & mkdir logs

1.3 修改配置文件

进入上个步骤的解压目录，打开配置文件（vi config/server.properties）

#配置kafka的监听端口
listeners=PLAINTEXT://:9092
#配置日志路径
log.dirs=/var/log/kafka/logs
#配置zookeeper
zookeeper.connect=localhost:2181
#调整日志保存时间为1小时
log.retention.hours=1

备注：如果要远程访问则需要配置advertised.listeners
advertised.listeners=PLAINTEXT://192.168.1.104:9092

1.4 copy到opt目录

\cp -rf kafka_2.12-3.4.0 /opt

二、启动

Kafka依赖ZooKeeper或者Kraft，需先启动依赖环境，本示例配置了ZooKeeper
进入安装路径

cd /opt/kafka_2.12-3.4.0

2.1 启动zookeeper

2.2 启动kafka

使用后台启动方式，保证关闭窗口时，不关闭kafka进程

./bin/kafka-server-start.sh -daemon ./config/server.properties
或者：
nohup ./bin/kafka-server-start.sh ./config/server.properties 1>/var/log/kafka 2>&1 &

启动后查看日志

三、验证

3.1 查看topic

./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

可以看到kafka3.4中，必须使用bootstrap-server参数。如果不小心使用了旧命令，则报错如下。修正该错误很简单，即使用3.4对应的命令（如上），而不是网上所说的：降低版本。

3.2 创建topic

./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytest

3.3 模拟发送和接收消息