kafka在centos上的安装配置指南

以下是在CentOS上安装配置Kafka的指南：

环境准备

• 安装Java：Kafka依赖Java，用命令sudo yum install java-1.8.0-openjdk-devel -y安装JDK 1.8，安装后通过java -version验证。
• 安装Zookeeper：Kafka需Zookeeper管理集群，可从官网下载安装包，解压后编辑zookeeper.properties配置数据目录等参数，再通过bin/zookeeper-server-start.sh启动。

下载解压Kafka

从Apache官网下载Kafka，如wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz，然后解压到指定目录，如/opt/kafka，用命令tar -xzvf kafka_2.12-3.5.2.tgz和sudo mv kafka_2.12-3.5.2 /opt/kafka。

配置Kafka

进入/opt/kafka/config目录，编辑server.properties文件，设置broker.id为唯一标识，listeners为监听地址和端口，advertised.listeners为对外地址和端口，log.dirs为日志存储目录，zookeeper.connect为Zookeeper连接地址等。

启动Kafka

可先手动启动，用命令nohup /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &，也可将其配置为系统服务，通过创建/etc/systemd/system/kafka.service文件并添加相关内容，然后使用sudo systemctl enable kafka和sudo systemctl start kafka启用和启动服务。

验证配置

使用命令bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test创建主题，再用bin/kafka-console-producer.sh和bin/kafka-console-consumer.sh发送和接收消息来验证。

配置防火墙

用命令sudo firewall-cmd --zone=public --add-port=9092/tcp --permanent和sudo firewall-cmd --reload开放Kafka使用的端口。