一、准备环境
首先,确保您的系统已经安装了Docker。如果您还没有安装Docker,请按照Docker官方网站的说明进行安装。
二、拉取Kafka镜像
打开终端,并运行以下命令来拉取Kafka镜像:
- 拉取Kafka镜像:docker pull wurstmeister/kafka
三、创建网络
在Docker中运行容器需要先创建网络。运行以下命令创建一个名为“kafka_network”的网络: - 创建网络:docker network create kafka_network
四、启动Zookeeper
Kafka依赖于Zookeeper,所以我们需要先启动Zookeeper。运行以下命令来启动Zookeeper容器: - 运行Zookeeper容器:docker run -d —name zookeeper -p 2181:2181 -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper:latest
五、启动Kafka
有了Zookeeper后,我们就可以启动Kafka了。运行以下命令来启动Kafka容器: - 运行Kafka容器:docker run -d —name kafka -p 9092:9092 —network kafka_network -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 wurstmeister/kafka:latest
六、验证Kafka是否运行成功
要验证Kafka是否运行成功,可以在终端中运行以下命令: - 查看Kafka容器日志:docker logs kafka 或者 输入netstat -tuln 查看本地端口占用情况,如果看到9092端口被占用,说明Kafka已经成功运行。您也可以使用其他Kafka客户端工具连接到localhost的9092端口来测试Kafka的功能。