centos中kafka配置步骤有哪些

在CentOS中配置Kafka，主要有以下步骤：

1. 安装Java环境：使用sudo yum install java-1.8.0-openjdk-devel -y命令安装OpenJDK 8，安装后通过java -version验证。
2. 下载并解压Kafka：从Apache官网下载所需版本，如wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz，然后解压到指定目录，如/opt/kafka。
3. 配置环境变量：将Kafka的bin目录添加到系统PATH中，编辑~/.bashrc文件，添加export PATH=$PATH:/opt/kafka/bin，再执行source ~/.bashrc使配置生效。
4. 配置Kafka：
   • 编辑config/server.properties文件，设置broker.id（每个节点唯一标识）、listeners（监听地址和端口）、log.dirs（日志存储目录）、zookeeper.connect（Zookeeper连接地址）等参数。
   • 若使用Zookeeper，需配置其数据目录等参数，编辑config/zookeeper.properties文件。
5. 启动服务：先启动Zookeeper服务（若使用），再启动Kafka服务，可使用./bin/zookeeper-server-start.sh config/zookeeper.properties和./bin/kafka-server-start.sh config/server.properties命令。
6. 验证配置：通过创建主题、发送和消费消息来验证，如./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test等命令。
7. 配置防火墙：使用firewall-cmd命令开放Kafka和Zookeeper所需端口，如sudo firewall-cmd --zone=public --add-port=9092/tcp --permanent和sudo firewall-cmd --zone=public --add-port=2181/tcp --permanent，然后执行sudo firewall-cmd --reload。