在Ubuntu上配置Apache Kafka涉及幾個步驟，包括安裝Java、Zookeeper和Kafka本身，配置相關文件，以及啟動服務。以下是一個詳細的步驟指南：
首先，確保你的系統上安裝了Java Development Kit (JDK)。你可以使用以下命令來安裝OpenJDK 8：
sudo apt update
sudo apt install openjdk-8-jdk
安裝完成后，驗證Java是否正確安裝：
java -version
Kafka依賴于Zookeeper，因此你需要先安裝它。你可以從Apache Zookeeper的官方網站下載Zookeeper的安裝包。
wget https://downloads.apache.org/zookeeper/zookeeper-3.5.12/zookeeper-3.5.12.tar.gz
tar -xzf zookeeper-3.5.12.tar.gz
sudo mv zookeeper-3.5.12 /usr/local/zookeeper
接下來，配置Zookeeper：
sudo cp /usr/local/zookeeper/conf/zoo_sample.cfg /usr/local/zookeeper/conf/zoo.cfg
sudo vi /usr/local/zookeeper/conf/zoo.cfg
在zoo.cfg文件中，確保以下配置項正確設置：
tickTime=2000
dataDir=/usr/local/zookeeper/data
clientPort=2181
保存并退出編輯器，然后啟動Zookeeper：
sudo /usr/local/zookeeper/bin/zkServer.sh start
驗證Zookeeper是否啟動成功：
sudo netstat -tulnp | grep 2181
下載Kafka的安裝包：
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -xzf kafka_2.12-3.5.2.tgz
sudo mv kafka_2.12-3.5.2 /usr/local/kafka
創建Kafka的日志目錄：
sudo mkdir -p /usr/local/kafka/logs
配置Kafka：
sudo vi /usr/local/kafka/config/server.properties
在server.properties文件中，確保以下配置項正確設置：
broker.id=0
listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/usr/local/kafka/logs
zookeeper.connect=localhost:2181
保存并退出編輯器，然后啟動Kafka：
sudo /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
驗證Kafka是否啟動成功：
sudo netstat -tulnp | grep 9092
創建一個名為test的Topic：
sudo /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
啟動Kafka生產者：
sudo /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
啟動Kafka消費者：
sudo /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
現在，你可以在生產者端輸入消息，并在消費者端查看這些消息。
為了方便使用Kafka命令，你可以將Kafka的bin目錄添加到系統的PATH環境變量中。編輯~/.bashrc或~/.profile文件：
echo 'export PATH=$PATH:/usr/local/kafka/bin' >> ~/.bashrc
source ~/.bashrc
停止Kafka服務：
sudo /usr/local/kafka/bin/kafka-server-stop.sh
停止Zookeeper服務：
sudo /usr/local/zookeeper/bin/zkServer.sh stop
以上步驟應該可以幫助你在Ubuntu上正確配置Kafka。請注意，根據你的具體需求，你可能需要調整一些配置項，例如端口號、日志目錄等。
