Docker安裝Kafka

一、安裝Docker

Docker是一款用於構建、發布和運行應用程序的開源工具。在安裝之前，需要確定服務器上沒有安裝舊版本的Docker。

1. 更新所有已安裝的軟件列表：

sudo apt update

2. 安裝Docker需要使用Docker存儲庫。因此，需要首先安裝如下的依賴包：

sudo apt install apt-transport-https ca-certificates curl software-properties-common

3. 添加Docker的GPG密鑰：

curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo apt-key add -

4. 添加Docker存儲庫：

sudo add-apt-repository "deb [arch=amd64] https://download.docker.com/linux/ubuntu bionic stable"

5. 最後，安裝Docker CE：

sudo apt install docker-ce

安裝完成後，可以使用以下命令啟動Docker服務：

sudo systemctl start docker

二、下載和運行Kafka鏡像

Kafka可以在Docker Hub上獲取，使用以下命令從Docker Hub下載：

docker pull wurstmeister/kafka

下載完成之後，使用以下命令運行Kafka容器：

docker run -d --name kafka -p 2181:2181 -p 9092:9092 --env KAFKA_ADVERTISED_HOST_NAME= --env KAFKA_ZOOKEEPER_CONNECT=:2181 wurstmeister/kafka

其中，為服務器IP地址。

三、創建Kafka主題

在運行Kafka容器的同時，可以使用以下的命令創建一個名為”test”的主題：

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

四、Kafka生產者和消費者實例

一個Kafka實例需要一個生產者和一個消費者。可以使用以下命令創建Kafka生產者：

docker exec -it kafka /bin/bash
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

然後可以輸入一些消息到Kafka主題：

Message 1
Message 2
Message 3

可以使用以下命令創建Kafka消費者：

docker exec -it kafka /bin/bash
/opt/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

可以看到，消費者會從主題中讀取所有的消息：

Message 1
Message 2
Message 3

五、總結

以上就是使用Docker安裝Kafka的步驟。通過Docker，可以快速搭建一個可測試的Kafka環境。