当前位置: 首页 > news >正文

docker部署kafka(单节点) + Springboot集成kafka

环境:

操作系统:win10

Docker:Docker Desktop 4.21.1 (114176)、Docker Engine v24.0.2

SpringBoot:2.7.15

步骤1:创建网络:

docker network create --subnet=172.18.0.0/16 net-kafka

步骤2:安装zk镜像

docker pull zookeeper:latestdocker run -d --restart always --name zk -p 2181:2181 --network net-kafka --ip 172.18.0.2 zookeeper

步骤3:安装kafka镜像

docker pull wurstmeister/kafkadocker run -d --restart always --name kafka -p 9092:9092 --network net-kafka --ip 172.18.0.3 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.18.0.2:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.18.0.3:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 -e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1 -e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=1 wurstmeister/kafka

使用命令行验证kafka

docker exec -it kafka /bin/bash# 查看主题
./kafka-topics.sh --list --bootstrap-server 172.18.0.3:9092# 生产者
./kafka-console-producer.sh --broker-list 172.18.0.3:9092 --topic 主题# 消费者
./kafka-console-consumer.sh --bootstrap-server 172.18.0.3:9092 --from-beginning --topic 主题

步骤4:安装各种控制台UI(可选)

应该只有使用zk集群或者kafka集群时才可用

# zkui
docker pull maauso/zkui
docker run -d --name zkui -p 9090:9090 -e ZKLIST=172.18.0.2:2181 maauso/zkui# kafka-ui
docker pull provectuslabs/kafka-ui
docker run -d --name kafka-ui -p 8080:8080 -e DYNAMIC_CONFIG_ENABLED=true provectuslabs/kafka-ui# kafka-manager
docker pull sheepkiller/kafka-manager
docker run -d --name kafka-manager -p 9000:9000 -e ZK_HOSTS=172.18.0.2:2181 sheepkiller/kafka-manager

步骤5:搭建Springboot开发环境

注意:

如果步骤3中,设置KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.18.0.3:9092,客户端应用控制台会出现如下图所示WARN

 

而且写消息时报错

也无法正常消费消息

改为:KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092,可以正常生产、消费。

完整demo工程下载。

http://www.lryc.cn/news/393025.html

相关文章:

  • 一.1.(3)半导体二极管基本电路的分析方法及常见应用电路
  • 银河麒麟V10 SP1 审计工具 auditd更新
  • JWT(Json Web Token)在.NET Core中的使用
  • 《QT从基础到进阶·四十三》QPlugin插件多线程问题和只有插件dll没有头文件和lib文件时调用插件中的方法
  • Android SurfaceFlinger——屏幕状态初始化(二十二)
  • 3101. 交替子数组计数 Medium
  • Linux系统基础命令行指令——Ubuntu
  • qt 读取配置文件
  • 拉格朗日插值法【python,算法】
  • 定个小目标之刷LeetCode热题(41)
  • Kotlin中的关键字
  • LabVIEW新能源汽车电池性能测试系统
  • Elasticsearch 实现 Word、PDF,TXT 文件的全文内容提取与检索
  • 深度学习赋能数据分析,联蔚盘云引领业务革新
  • Arthas实战(5)- 项目性能调优
  • 昇思25天学习打卡营第7天|Pix2Pix实现图像转换
  • 单选多选提交问卷,代码示例
  • mars3d加载wms服务或者wmts服务注意事项
  • 【机器学习】机器学习与自然语言处理的融合应用与性能优化新探索
  • ubuntu优化
  • 使用 HBuilder X 进行 uniapp 小程序开发遇到的问题合集
  • Python爬虫获取视频
  • Python自动化,实现自动登录并爬取商品数据,实现数据可视化
  • 计算机网络——数据链路层(以太网)
  • Java ORM框架FastMybatis踩坑
  • AI是在帮助开发者还是取代他们?
  • C. Theofanis‘ Nightmare
  • 加密货币大利好!9月降息概率突破70%!美国可能大幅降息或多次降息?
  • Dns被莫名篡改的逆向分析定位(笔记)
  • SpringBoot中整合ONLYOFFICE在线编辑