在Ubuntu上安裝Apache Kafka的步驟如下:
首先,確保你的系統包是最新的:
sudo apt update
sudo apt upgrade -y
Kafka需要Java運行時環境(JRE)或Java開發工具包(JDK)。你可以安裝OpenJDK:
sudo apt install openjdk-11-jdk -y
驗證安裝:
java -version
你可以從Apache Kafka的官方網站下載最新版本的Kafka。以下是下載和解壓的命令:
wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz
tar -xzf kafka_2.13-3.5.0.tgz
cd kafka_2.13-3.5.0
請注意,下載鏈接中的版本號可能會有所不同,請訪問Apache Kafka官方下載頁面獲取最新版本。
Kafka使用Zookeeper進行集群管理。首先啟動Zookeeper服務器:
bin/zookeeper-server-start.sh config/zookeeper.properties &
在另一個終端窗口中啟動Kafka服務器:
bin/kafka-server-start.sh config/server.properties &
你可以使用以下命令創建一個新的Kafka主題:
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
這里,test
是主題名稱,localhost:9092
是Kafka服務器的地址,--replication-factor
是副本因子,--partitions
是分區數。
你可以使用以下命令查看所有主題:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
你可以使用以下命令啟動一個生產者來發送消息到一個主題:
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和Zookeeper:
# 停止消費者
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092 --exit-on-empty
# 停止生產者
Ctrl+C
# 停止Kafka服務器
bin/kafka-server-stop.sh
# 停止Zookeeper服務器
bin/zookeeper-server-stop.sh
如果你需要從其他機器訪問Kafka,可能需要配置防火墻以允許端口9092的流量:
sudo ufw allow 9092/tcp
通過以上步驟,你應該能夠在Ubuntu上成功安裝并運行Apache Kafka。