在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联系删除