在CentOS上配置Apache Kafka涉及几个步骤，包括安装Java（Kafka的依赖项）、下载和配置Kafka服务器以及启动Kafka服务。以下是一个基本的指南：
Kafka需要Java运行时环境。你可以使用以下命令安装OpenJDK：
sudo yum install java-1.8.0-openjdk-devel
安装完成后，验证Java安装：
java -version
访问Kafka官方网站下载页面（https://kafka.apache.org/downloads），选择适合你系统的版本并下载。你可以使用wget命令来下载：
wget https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz
下载完成后，解压文件到一个目录，例如/opt：
sudo tar -xzf kafka_2.13-2.8.0.tgz -C /opt
进入Kafka目录并进行基本配置：
cd /opt/kafka_2.13-2.8.0/config
编辑server.properties文件来配置Kafka服务器：
nano server.properties
在这个文件中，你可以设置以下参数：
broker.id: 每个broker的唯一ID。listeners: Kafka监听的地址和端口。log.dirs: Kafka日志存储的目录。zookeeper.connect: Zookeeper连接字符串。例如：
broker.id=1
listeners=PLAINTEXT://your.server.ip:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
首先启动Zookeeper服务：
bin/zookeeper-server-start.sh config/zookeeper.properties
然后启动Kafka服务器：
bin/kafka-server-start.sh config/server.properties
创建一个Topic来测试Kafka：
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
列出所有Topic来验证创建是否成功：
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
生产消息到Topic：
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
在另一个终端消费消息：
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
输入一些文本并按回车，你应该能在消费者终端看到这些消息。
为了使Kafka服务在系统启动时自动运行，你可以创建一个systemd服务文件：
sudo nano /etc/systemd/system/kafka.service
添加以下内容：
[Unit]
Description=Apache Kafka Server
After=network.target
[Service]
Type=simple
User=kafka
ExecStart=/opt/kafka_2.13-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.13-2.8.0/config/server.properties
ExecStop=/opt/kafka_2.13-2.8.0/bin/kafka-server-stop.sh
Restart=on-failure
[Install]
WantedBy=multi-user.target
保存并退出，然后启用并启动服务：
sudo systemctl enable kafka
sudo systemctl start kafka
现在，Kafka应该会在系统启动时自动运行。
请注意，这些步骤提供了一个基本的Kafka安装和配置过程。根据你的具体需求，可能需要进行更多的配置和优化。
