云南省建设厅官方网站证书,wordpress小说网站模板下载,楼盘建设信息网站,网站开发客户需求docker-compose 安装带kafka-ui 的kafka集群
在日常的工作当中#xff0c;kafka集群作为常用的中间件#xff0c;其搭建过程略显繁琐#xff0c;需要配置的文件颇多#xff0c;为了方便各位初学者快速体验kafka的魅力#xff0c;本文采取一键式安装kafka-3.3.1#xff0…docker-compose 安装带kafka-ui 的kafka集群
在日常的工作当中kafka集群作为常用的中间件其搭建过程略显繁琐需要配置的文件颇多为了方便各位初学者快速体验kafka的魅力本文采取一键式安装kafka-3.3.1不带zookeeper版本的集群化安装。仅需将下面配置中的10.0.0.147 改为自己本机的ip即可
version: 3
services:#kafka可视化工具kafka-ui:container_name: kafka-uiimage: provectuslabs/kafka-ui:latestports:- 8989:8080depends_on:- kafka1- kafka2- kafka3environment:- KAFKA_CLUSTERS_0_NAMEkafkaCluster- KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS10.0.0.147:9192,10.0.0.147:9292,10.0.0.147:9392- DYNAMIC_CONFIG_ENABLEDtruenetworks:- mynetwork# kafka集群kafka1:image: bitnami/kafka:3.3.1container_name: kafka1user: rootports:- 9192:9092- 9193:9093environment:### 通用配置# 允许使用kraft即Kafka替代Zookeeper- KAFKA_ENABLE_KRAFTyes# kafka角色做broker也要做controller- KAFKA_CFG_PROCESS_ROLESbroker,controller# 指定供外部使用的控制类请求信息- KAFKA_CFG_CONTROLLER_LISTENER_NAMESCONTROLLER# 定义kafka服务端socket监听端口- KAFKA_CFG_LISTENERSPLAINTEXT://:9092,CONTROLLER://:9093# 定义安全协议- KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT# 使用Kafka时的集群id集群内的Kafka都要用这个id做初始化生成一个UUID即可- KAFKA_KRAFT_CLUSTER_IDLelM2dIFQkiUFvXCEcqRWA# 集群地址- KAFKA_CFG_CONTROLLER_QUORUM_VOTERS1kafka1:9093,2kafka2:9093,3kafka3:9093# 允许使用PLAINTEXT监听器默认false不建议在生产环境使用- ALLOW_PLAINTEXT_LISTENERyes# 设置broker最大内存和初始内存- KAFKA_HEAP_OPTS-Xmx512M -Xms256M# 允许自动创建主题- KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEtrue# 消息保留时长毫秒保留7天- KAFKA_LOG_RETENTION_MS604800000### broker配置# 定义外网访问地址宿主机ip地址和端口- KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://10.0.0.147:9192# broker.id必须唯一- KAFKA_BROKER_ID1volumes:- /data/bitnami/kafka1:/bitnami/kafkanetworks:- mynetworkkafka2:image: bitnami/kafka:3.3.1container_name: kafka2user: rootports:- 9292:9092- 9293:9093environment:### 通用配置# 允许使用kraft即Kafka替代Zookeeper- KAFKA_ENABLE_KRAFTyes# kafka角色做broker也要做controller- KAFKA_CFG_PROCESS_ROLESbroker,controller# 指定供外部使用的控制类请求信息- KAFKA_CFG_CONTROLLER_LISTENER_NAMESCONTROLLER# 定义kafka服务端socket监听端口- KAFKA_CFG_LISTENERSPLAINTEXT://:9092,CONTROLLER://:9093# 定义安全协议- KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT# 使用Kafka时的集群id集群内的Kafka都要用这个id做初始化生成一个UUID即可- KAFKA_KRAFT_CLUSTER_IDLelM2dIFQkiUFvXCEcqRWA# 集群地址- KAFKA_CFG_CONTROLLER_QUORUM_VOTERS1kafka1:9093,2kafka2:9093,3kafka3:9093# 允许使用PLAINTEXT监听器默认false不建议在生产环境使用- ALLOW_PLAINTEXT_LISTENERyes# 设置broker最大内存和初始内存- KAFKA_HEAP_OPTS-Xmx512M -Xms256M# 允许自动创建主题- KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEtrue# 消息保留时长毫秒保留7天- KAFKA_LOG_RETENTION_MS604800000### broker配置# 定义外网访问地址宿主机ip地址和端口- KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://10.0.0.147:9292# broker.id必须唯一- KAFKA_BROKER_ID2volumes:- /data/bitnami/kafka2:/bitnami/kafkanetworks:- mynetworkkafka3:image: bitnami/kafka:3.3.1container_name: kafka3user: rootports:- 9392:9092- 9393:9093environment:### 通用配置# 允许使用kraft即Kafka替代Zookeeper- KAFKA_ENABLE_KRAFTyes# kafka角色做broker也要做controller- KAFKA_CFG_PROCESS_ROLESbroker,controller# 指定供外部使用的控制类请求信息- KAFKA_CFG_CONTROLLER_LISTENER_NAMESCONTROLLER# 定义kafka服务端socket监听端口- KAFKA_CFG_LISTENERSPLAINTEXT://:9092,CONTROLLER://:9093# 定义安全协议- KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT# 使用Kafka时的集群id集群内的Kafka都要用这个id做初始化生成一个UUID即可- KAFKA_KRAFT_CLUSTER_IDLelM2dIFQkiUFvXCEcqRWA# 集群地址- KAFKA_CFG_CONTROLLER_QUORUM_VOTERS1kafka1:9093,2kafka2:9093,3kafka3:9093# 允许使用PLAINTEXT监听器默认false不建议在生产环境使用- ALLOW_PLAINTEXT_LISTENERyes# 设置broker最大内存和初始内存- KAFKA_HEAP_OPTS-Xmx512M -Xms256M# 允许自动创建主题- KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEtrue# 消息保留时长毫秒保留7天- KAFKA_LOG_RETENTION_MS604800000### broker配置# 定义外网访问地址宿主机ip地址和端口- KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://10.0.0.147:9392# broker.id必须唯一- KAFKA_BROKER_ID3volumes:- /data/bitnami/kafka3:/bitnami/kafkanetworks:- mynetworknetworks:mynetwork:driver: bridge
执行 命令安装即可
docker-compose up -d
