在 Debian 系統上管理 Kafka 主題,你需要遵循以下步驟:
安裝 Java: Kafka 需要 Java 運行環境,通常是 Java 8 或 Java 11。你可以使用以下命令安裝 OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
安裝完成后,驗證 Java 是否正確安裝:
java -version
下載并安裝 Kafka:
你可以從 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
為了方便管理,你可以創建一個符號鏈接:
sudo ln -s kafka_2.13-3.2.0 /opt/kafka
啟動 Zookeeper 和 Kafka Server: Kafka 使用 Zookeeper 來管理集群和主題。首先啟動 Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
然后在另一個終端中啟動 Kafka 服務器:
bin/kafka-server-start.sh config/server.properties
為了方便,你可以使用 screen
或 tmux
在后臺運行這些進程。
創建 Kafka 主題: 使用以下命令創建一個新的 Kafka 主題:
bin/kafka-topics.sh --create --topic your_topic_name --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
替換 your_topic_name
為你想要的主題名稱。
查看 Kafka 主題列表: 要列出所有可用的 Kafka 主題,使用以下命令:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
刪除 Kafka 主題: 如果你需要刪除一個主題,可以使用以下命令:
bin/kafka-topics.sh --delete --topic your_topic_name --bootstrap-server localhost:9092
注意:只有當主題沒有被任何 broker 使用時,才能刪除它。
管理 Kafka 主題配置: 你可以修改現有主題的配置,例如增加分區數量或更改復制因子:
bin/kafka-topics.sh --alter --topic your_topic_name --bootstrap-server localhost:9092 --partitions 3
更改配置項的命令如下:
bin/kafka-configs.sh --entity-type topics --entity-name your_topic_name --alter --add-config config_name=config_value --bootstrap-server localhost:9092
請記住,這些步驟假設 Kafka 集群只運行在本地機器上,并且使用默認端口 9092。如果你的 Kafka 集群配置不同,你需要相應地調整命令中的參數。此外,生產環境中通常會有多個 broker 和更復雜的配置,這些步驟僅適用于基本的本地測試和開發環境。