在Debian系統下啟動Kafka,你需要遵循以下步驟:
安裝Java: Kafka需要Java運行環境,首先確保你的系統上已經安裝了Java。你可以使用以下命令來安裝OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
安裝完成后,你可以通過運行java -version來檢查Java是否正確安裝。
下載并解壓Kafka: 你可以從Apache Kafka的官方網站下載最新版本的Kafka。使用以下命令下載并解壓:
wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0
請注意,你應該下載與你系統兼容的Kafka版本。上面的命令是下載Kafka 3.2.0版本的示例。
啟動Zookeeper: Kafka使用Zookeeper來管理集群和元數據。在啟動Kafka服務器之前,你需要先啟動Zookeeper服務。在Kafka目錄下,使用以下命令啟動Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
Zookeeper默認會在端口2181上運行。
啟動Kafka服務器: 在另一個終端窗口中,你可以在Kafka目錄下啟動Kafka服務器(broker):
bin/kafka-server-start.sh config/server.properties
Kafka默認會在端口9092上運行。
創建Topic(可選): 如果你需要創建一個新的Topic,可以使用以下命令:
bin/kafka-topics.sh --create --topic your_topic_name --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
將your_topic_name替換為你想要的Topic名稱。
啟動Kafka生產者或消費者(可選):
啟動生產者:
bin/kafka-console-producer.sh --topic your_topic_name --bootstrap-server localhost:9092
啟動消費者:
bin/kafka-console-consumer.sh --topic your_topic_name --from-beginning --bootstrap-server localhost:9092
現在,Kafka應該在Debian系統上運行了。如果你遇到任何問題,請檢查Kafka和Zookeeper的日志文件,這些文件通常位于logs目錄下。