在CentOS上配置Apache Kafka涉及多個步驟，包括下載和安裝Kafka、配置Kafka服務器以及啟動Kafka服務。以下是一個基本的指南，幫助你在CentOS上配置Kafka。
首先，你需要下載并解壓Kafka。你可以從Kafka官方網站下載最新版本的Kafka。
# 下載Kafka
wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
# 解壓Kafka
tar -xzf kafka_2.13-3.2.0.tgz
mv kafka_2.13-3.2.0 /opt/kafka
Kafka的主要配置文件是server.properties，位于/opt/kafka/config目錄下。你需要編輯這個文件來配置Kafka服務器。
# 進入Kafka配置目錄
cd /opt/kafka/config
# 備份原始配置文件
cp server.properties server.properties.bak
# 編輯server.properties文件
vi server.properties
以下是一些常見的配置項：
broker.id: 每個broker的唯一標識符。listeners: 監聽地址和端口。log.dirs: 日志文件存儲目錄。zookeeper.connect: Zookeeper連接字符串。示例配置：
broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
啟動Kafka服務器需要先啟動Zookeeper，然后啟動Kafka broker。
# 進入Kafka bin目錄
cd /opt/kafka/bin
# 啟動Zookeeper
./zookeeper-server-start.sh ../config/zookeeper.properties &
# 啟動Kafka broker
./kafka-server-start.sh ../config/server.properties &
你可以使用kafka-topics.sh腳本來創建一個Topic。
# 創建一個名為my-topic的Topic，分區數為3，副本因子為2
./kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2 --bootstrap-server localhost:9092
你可以使用kafka-console-producer.sh和kafka-console-consumer.sh腳本來驗證Kafka是否正常工作。
# 生產者：發送消息到my-topic
./kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092
# 消費者：從my-topic消費消息
./kafka-console-consumer.sh --topic my-topic --from-beginning --bootstrap-server localhost:9092
你可以使用以下命令來停止Kafka服務器。
# 停止Kafka broker
./kafka-server-stop.sh
# 停止Zookeeper
./zookeeper-server-stop.sh
以上步驟提供了一個基本的Kafka配置指南。根據你的具體需求，你可能需要進一步調整配置文件中的參數。
