Docker是最流行的容器引擎之一,软件行业使用它来创建、打包和部署应用程序。本教程学习如何使用Docker构建Apache Kafka。
安装单节点安装单节点Kafka代理需要能够满足本地开发需求。我们先来了解一下单节点安装。
Docker-compose.yml配置使用Apache Kafka服务。首先,你需要启动动物园管理员服务。这可以通过在docker-compose.yml文件中配置依赖关系来实现,但要确保zookeeper服务总是在Kafka服务之前启动,否则Zookeeper最后停止。
首先,创建docker-compose.yml文件并添加两个服务:zookeeper和kafka:
版本:' 2 '服务:ZOOKEEPER:image:confluentinc/cp-zookeeper:最新环境:ZOOKEEPER _ CLIENT _ PORT:2181 ZOOKEEPER _ TICK _ TIME:2000端口:-22181:2181 KAFKA:image:c onfluentinc/cp-KAFKA:最新依赖项:-ZOOKEEPER端口:- 29092:29092环境:KAFKA _ BROKER _ ID:1 KAFKA _ ZOOKEEPER _ CONNECT:z ookeeper:2100同样,kafka通过端口29092暴露给主机应用程序,但它实际上是在容器的端口9092中。需要配置KAFKA_ADVERTISED_LISTENERS属性。
使用以下命令启动容器并启动kafka服务:
$ docker-compose up-d创建网络“Kafka _ default ”,默认驱动程序创建Kafka _ zookeeper _ 1...完成创建卡夫卡_卡夫卡_ 1...Done下面的两个服务正在通过nc命令监听它们各自的端口:
$ nc -z本地主机22181连接到本地主机端口22181
安装集群环境需要更稳定的环境。以下文件扩展docker-compose.yml以创建多节点集群环境:
Docker-compose.yml配置集群安装需要zookeeper和kafka的多个实例。为zookeeper和Kafka添加了以下服务:
---版本:' 2 '服务:ZOOKEEPER -1:image:confluent Inc/cp-ZOOKEEPER:最新环境:ZOOKEEPER _ CLIENT _ PORT:2181 ZOOKEEPER _ TICK _ TIME:2000端口:-22181:2181 ZOOKEEPER -2:image:confluent Inc/cp-ZOOKEEPER:最新环境:ZOOKEEPER _ CLIENT _ PORT:2181 ZOOKEEPER _ TIME:2000端口:- 32181:2181 plaintext _ host:plaintext kafka _ inter _ BROKER _ listener _ name:plaintext Kafka _ offsets _ topic _ replication _ factor:1您必须确保Kafka服务名称是唯一的,该名称由KAFKA_BROKER_ID属性设置。 并且每个服务必须公开一个唯一的主机端口。虽然zookeeper-1和zookeeper-2监听端口2181,但它们分别是主机端口22181和32181。同样,kafka-1和kafka-2服务对应的主机端口分别为29092和39092。
启动kafka集群现在使用docker-compose命令启动集群:
$ docker -用默认驱动程序组成-d创建网络“kafka_default”创建kafka_zookeeper-1_1...完成创建卡夫卡_动物园管理员-2_1...e创作卡夫卡_卡夫卡-2 _ 1...完成创建Kafka _ Kafka-1 _ 1...Done启动,用Kafka工具连接到集群,地址用逗号分隔,只读多个zookeeper地址和端口:
本文总结了使用Docker技术创建单个Kafka节点和Kafka集群环境,并使用可视化工具连接服务来查看代理服务器的配置信息。
关于使用Docker构建Apache Kafka环境的这篇文章到此结束。关于Docker Apache Kafka环境的更多信息,请搜索主机频道zhujipindao之前的文章。或者继续浏览下面的相关文章。希望大家支持主机频道zhujipindao。以后多来com!
评论前必须登录!
注册