如何在Linux上安裝Kafka

Kafka是由Apache軟件基金會開發的一個開源事件流處理平台，它由數個Broker節點組成，支持發布-訂閱消息服務。

一、安裝Java開發環境

在安裝Kafka之前，需要先安裝Java開發環境，可以通過以下命令來檢查是否已經安裝了Java：

java -version

如果沒有安裝Java，可以使用以下命令在Ubuntu上安裝：

sudo apt update
sudo apt install default-jre
sudo apt install default-jdk

在CentOS上安裝Java：

sudo yum install java-1.8.0-openjdk

二、下載和安裝Kafka

可以從Kafka的官網下載Kafka二進制文件並解壓縮。

wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz
tar -xzf kafka_2.12-2.6.0.tgz
cd kafka_2.12-2.6.0

三、啟動Kafka Broker

在啟動Kafka之前，可以在config/server.properties文件中修改一些配置項，比如broker.id、listeners、log.dirs等等。

接下來，可以使用以下命令啟動Kafka Broker：

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

在啟動之後，可以使用以下命令來檢查Kafka是否正常啟動：

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

如果顯示無誤，說明Kafka已經正常啟動。

四、創建和使用Topic

在Kafka中，可以使用以下命令來創建一個Topic：

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

可以使用以下命令來查看已經創建的Topics：

bin/kafka-topics.sh --list --zookeeper localhost:2181

可以使用以下命令來往Topic中發送消息：

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

可以使用以下命令來接收Topic中的消息：

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

五、Kafka常用命令

• 創建Topic: bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
• 查看Topic列表: bin/kafka-topics.sh –list –zookeeper localhost:2181
• 查看Topic詳情: bin/kafka-topics.sh –describe –zookeeper localhost:2181 –topic test
• 往Topic中寫入消息: bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test
• 從Topic中讀取消息: bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from-beginning
• 刪除Topic: bin/kafka-topics.sh –zookeeper localhost:2181 –delete –topic test
• 開啟Kafka管理功能: bin/kafka-server-start.sh config/server.properties –override delete.topic.enable=true