一、安装Docker
Docker是一款用于构建、发布和运行应用程序的开源工具。在安装之前，需要确定服务器上没有安装旧版本的Docker。
1. 更新所有已安装的软件列表：
sudo apt update2. 安装Docker需要使用Docker存储库。因此，需要首先安装如下的依赖包：
sudo apt install apt-transport-https ca-certificates curl software-properties-common3. 添加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环境。
原创文章，作者：MFWZD，如若转载，请注明出处：https://www.506064.com/n/332973.html
微信扫一扫 
支付宝扫一扫 