如何在 Ubuntu 上配置 Kafka

在 Ubuntu 上配置 Apache Kafka 需要幾個步驟，包括安裝 Java、下載 Kafka、配置 Kafka 服務器和客戶端。以下是一個詳細的指南：

1. 安裝 Java

Kafka 需要 Java 運行環境。你可以使用 OpenJDK 或 Oracle JDK。以下是安裝 OpenJDK 的步驟：

sudo apt update
sudo apt install openjdk-11-jdk

驗證 Java 安裝：

java -version

2. 下載 Kafka

訪問 Apache Kafka 官方網站 下載最新版本的 Kafka。你可以使用 wget 命令下載：

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

3. 啟動 Zookeeper

Kafka 使用 Zookeeper 進行集群管理。首先啟動 Zookeeper：

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

4. 啟動 Kafka 服務器

在另一個終端窗口中啟動 Kafka 服務器：

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

5. 創建主題

創建一個 Kafka 主題，例如 my-topic：

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

6. 驗證 Kafka 主題

列出所有主題以驗證 my-topic 是否已創建：

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

查看 my-topic 的詳細信息：

bin/kafka-topics.sh --describe --topic my-topic --bootstrap-server localhost:9092

7. 生產者和消費者

你可以使用 Kafka 自帶的命令行工具來生產和消費消息。

生產者

發送消息到 my-topic：

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

在終端中輸入消息并按回車鍵發送。

消費者

從 my-topic 消費消息：

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

這將顯示 my-topic 中的所有消息。

8. 配置文件

Kafka 的配置文件位于 config 目錄下。你可以根據需要修改這些文件來調整 Kafka 的行為。例如，你可以修改 server.properties 文件來更改 Kafka 服務器的配置。

9. 停止 Kafka 和 Zookeeper

停止 Kafka 服務器：

bin/kafka-server-stop.sh

停止 Zookeeper：

bin/zookeeper-server-stop.sh

通過以上步驟，你已經在 Ubuntu 上成功配置了 Apache Kafka。你可以根據需要進一步調整和擴展 Kafka 的配置。