在Docker中部署Kafka集群，可以按照以下步骤进行：
（图片来源网络，侵删）
1. 安装Docker和Docker Compose
首先确保你的计算机已经安装了Docker和Docker Compose，如果没有安装，可以参考官方文档进行安装：
Docker: https://docs.docker.com/engine/install/
Docker Compose: https://docs.docker.com/compose/install/
2. 创建Docker Compose文件
创建一个名为dockercompose.yml的文件，内容如下：
version: \'3\'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
"2181:2181"
kafka:
image: wurstmeister/kafka
ports:
"9092:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: localhost
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
volumes:
/var/run/docker.sock:/var/run/docker.sock
depends_on:
zookeeper
这个文件定义了两个服务：zookeeper和kafka。zookeeper使用wurstmeister/zookeeper镜像，端口映射为2181:2181；kafka使用wurstmeister/kafka镜像，端口映射为9092:9092。kafka服务还设置了环境变量KAFKA_ADVERTISED_HOST_NAME和KAFKA_ZOOKEEPER_CONNECT，并依赖于zookeeper服务。
3. 启动Kafka集群
在dockercompose.yml文件所在目录下，运行以下命令启动Kafka集群：
dockercompose up d
等待一段时间，直到Kafka集群完全启动。
4. 验证Kafka集群是否正常运行
可以使用以下命令查看Kafka集群的运行状态：
dockercompose logs
如果看到类似以下的输出，说明Kafka集群已经正常运行：
kafka_1 | [20220101 00:00:00,000] INFO [SocketServer brokerId=0] Started processors for epoch 0 (kafka.network.RequestChannel$) kafka_1 | [20220101 00:00:00,000] INFO Kafka version : 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) kafka_1 | [20220101 00:00:00,000] INFO [KafkaServer id=0] Starting the Kafka server (kafka.server.KafkaServer)
至此，你已经在Docker中成功部署了一个Kafka集群，接下来你可以使用Kafka客户端进行生产和消费操作。
本文来自投稿，不代表重蔚自留地立场，如若转载，请注明出处https://www.cwhello.com/488290.html
如有侵犯您的合法权益请发邮件951076433@qq.com联系删除
