ubuntu上kafka配置步驟

在Ubuntu上配置Apache Kafka的步驟如下：

1. 安裝Java環境

首先，確保你的系統上已經安裝了Java。你可以使用以下命令來安裝OpenJDK 8：

sudo apt update
sudo apt install openjdk-8-jdk

安裝完成后，驗證Java是否安裝成功：

java -version

2. 下載并解壓Kafka

從Apache Kafka官網下載你需要的Kafka版本。例如，下載Kafka 3.5.2版本：

wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz

然后解壓下載的tgz文件：

tar -xzvf kafka_2.12-3.5.2.tgz

3. 配置Zookeeper

進入解壓后的Kafka目錄，然后進入config目錄，復制zookeeper.properties文件并重命名為zoo.cfg：

cd kafka_2.12-3.5.2/config
cp zookeeper.properties zoo.cfg

編輯zoo.cfg文件，設置以下參數：

tickTime=2000
dataDir=/var/lib/zookeeper
clientPort=2181

4. 啟動Zookeeper

在Kafka目錄下，啟動Zookeeper服務：

./bin/zookeeper-server-start.sh ./zoo.cfg

5. 配置Kafka

同樣在Kafka目錄下，編輯server.properties文件，設置以下參數：

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

將your_server_ip替換為你的服務器IP地址。

6. 啟動Kafka

啟動Kafka服務：

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

7. 創建Topic

創建一個新的Kafka Topic：

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

8. 測試Kafka

啟動生產者發送消息到Topic：

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

在另一個終端啟動消費者接收消息：

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

至此，你已經在Ubuntu上成功配置了Kafka。