在CentOS上穩定運行Kafka需要考慮多個方面，包括安裝、配置、資源分配、性能優化以及高可用性設置。以下是一個詳細的指南：
Kafka需要Java運行環境，首先確保你的系統上安裝了Java。如果沒有，可以通過以下命令安裝：
sudo yum install java-1.8.0-openjdk-devel -y
驗證Java安裝成功：
java -version
從Apache官網下載適合的版本，例如Kafka 3.5.2：
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
解壓并移動到指定目錄：
tar -zxvf kafka_2.12-3.5.2.tgz
sudo mv kafka_2.12-3.5.2 /opt/kafka
將Kafka的bin目錄添加到系統的PATH中：
echo 'export PATH=$PATH:/opt/kafka/bin' >> ~/.bashrc
source ~/.bashrc
進入Kafka目錄并編輯config/server.properties文件：
cd /opt/kafka
nano config/server.properties
關鍵配置項包括：
broker.id: 每個節點的唯一標識。listeners: 監聽協議及地址。log.dirs: Kafka日志存儲目錄。zookeeper.connect: Zookeeper地址。示例配置：
broker.id=1
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
如果使用Kafka 2.8.0及以上版本，Kafka內置了Zookeeper，只需確保Zookeeper配置正確。進入Zookeeper目錄并編輯conf/zoo.cfg文件：
cd /opt/kafka
nano config/zookeeper.properties
關鍵配置項包括：
dataDir: Zookeeper數據目錄。clientPort: Zookeeper客戶端連接端口。示例配置：
dataDir=/tmp/zookeeper
clientPort=2181
啟動Zookeeper服務：
/opt/kafka/bin/zookeeper-server-start.sh config/zookeeper.properties
啟動Kafka服務：
/opt/kafka/bin/kafka-server-start.sh config/server.properties
使用以下命令創建一個主題并測試：
/opt/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
發送消息：
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
消費消息：
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
為了實現高可用性，需要配置Kafka集群和副本機制。
在每個Kafka節點上編輯config/server.properties文件，確保broker.id和listeners配置正確。然后啟動Kafka服務。
創建一個測試主題并指定副本數：
/opt/kafka/bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2 --zookeeper localhost:2181
合理分配CPU、內存和磁盤資源。例如，為Kafka Broker分配足夠的內存：
export KAFKA_HEAP_OPTS="-Xms4G -Xmx4G"
使用Kafka自帶的命令行工具監控集群狀態和性能指標：
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper localhost:2181
定期檢查和清理日志文件，確保磁盤空間充足。
通過以上步驟和建議，你可以在CentOS上穩定運行Kafka，并確保其高可用性和性能。需要注意的是，這些配置和優化策略需要根據具體的業務需求和硬件環境進行調整。
