centos如何安裝kafka

在CentOS上安裝Kafka的步驟如下：

前提條件

1. Java環境：Kafka需要Java環境，確保已經安裝了Java 8或更高版本。

   java -version
   

2. Zookeeper：Kafka依賴Zookeeper進行集群管理，因此需要先安裝并啟動Zookeeper。

安裝步驟

1. 安裝Java

如果尚未安裝Java，可以使用以下命令安裝OpenJDK：

sudo yum install java-1.8.0-openjdk-devel

2. 下載Kafka

訪問Kafka官方網站下載最新版本的Kafka。假設下載的是kafka_2.13-3.2.0.tgz：

wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz

3. 解壓Kafka

將下載的文件解壓到指定目錄，例如/opt：

sudo tar -xzf kafka_2.13-3.2.0.tgz -C /opt

4. 配置Kafka

進入Kafka目錄并進行基本配置：

cd /opt/kafka_2.13-3.2.0

4.1 配置Zookeeper連接

編輯config/server.properties文件，設置Zookeeper的連接信息：

zookeeper.connect=localhost:2181

4.2 配置Kafka監聽地址

確保listeners和advertised.listeners配置正確，以便客戶端可以連接到Kafka服務器：

listeners=PLAINTEXT://your_server_ip:9092
advertised.listeners=PLAINTEXT://your_server_ip:9092

5. 啟動Kafka

啟動Kafka服務器：

bin/kafka-server-start.sh config/server.properties

6. 啟動Zookeeper

啟動Zookeeper服務：

bin/zookeeper-server-start.sh config/zookeeper.properties

驗證安裝

1. 創建Topic 創建一個名為test-topic的Topic：

   bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
   

2. 查看Topic列表 查看所有Topic：

   bin/kafka-topics.sh --list --bootstrap-server localhost:9092
   

3. 生產消息 向test-topic發送一條消息：

   bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
   

   在控制臺輸入消息并按回車鍵發送。

4. 消費消息 從test-topic消費消息：

   bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092
   

通過以上步驟，你應該能夠在CentOS上成功安裝并運行Kafka。如果有任何問題，請檢查日志文件以獲取更多信息。