news 2026/4/23 1:07:08

Docker(单机Kafka安装)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Docker(单机Kafka安装)
1. pull镜像
docker pull zookeeper docker pull wurstmeister/kafka
2. 创建通信网络。zookeeper和kafka之间的通信
docker network create kafka_zk_net
查看网络 docker network ls docker network inspect kafka_zk_net
3. 创建容器
docker run --net=kafka_zk_net --name zookeeper -p 21810:2181 -d docker.io/zookeeper
docker run --net=kafka_zk_net --name kafka -p 9093:9092 \ --link zookeeper \ -e KAFKA_BROKER_ID=4 \ -e KAFKA_ZOOKEEPER_CONNECT=172.18.0.2:2181 \ -e KAFKA_ADVERTISED_HOST_NAME=43.142.80.86 \ -e KAFKA_ADVERTISED_PORT=9092 \ -d wurstmeister/kafka

KAFKA_ADVERTISED_HOST_NAME参数需要设置为宿主机地址(或服务器外网地址)
KAFKA_ZOOKEEPER_CONNECT参数设置zookeeper容器内部地址和端口,查看指令为docker inspect kafka_zk_net

"a3300202308bec58530baaa31247f1870def61f07208e72b18ab10f0bb44c5d9": { "Name": "zookeeper", "EndpointID": "ae59143a1679b7534df41b9a0aa44164c26a6841a04893a3053f14c73cbe2df9", "MacAddress": "02:42:ac:12:00:02", "IPv4Address": "172.18.0.2/16", "IPv6Address": "" }
4. 启动生产者和消费者
docker exec -it kafka bash cd opt/kafka_2.13-2.8.1/bin/ ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic1 生产者 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic1 --from-beginning 消费者
5. bug

1. 启动consumer发现: Error while fetching metadata with correlation id

修复步骤:
vi /opt/kafka/kafka/config/server.properties

添加:

listeners=PLAINTEXT://localhost:9092 advertised.listeners=PLAINTEXT://localhost:9092

kafka listeners和advertised配置

发现:Docker:bash: vi: command not found

apt-get update apt-get install vim

停止kafka容器和重启

docker stop kafka docker restart kafka docker restart kafka

成功截图

ps:如果你修改容器文件导致无法启动容器可以参考:
Docker容器无法启动,里面的配置文件如何修改

非内网连接,必须构建时指定端口和网址...测试了一下,修改是没用的,应该zookeeper已经存了元数据了..

docker run --net=kafka_zk_net --name kafka -p 9093:9092 \ --link zookeeper \ -e KAFKA_BROKER_ID=4 \ -e KAFKA_ZOOKEEPER_CONNECT=172.18.0.2:2181 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://43.142.80.86:9093 \ -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \ -d wurstmeister/kafka*/

AI大模型学习福利

作为一名热心肠的互联网老兵,我决定把宝贵的AI知识分享给大家。 至于能学习到多少就看你的学习毅力和能力了 。我已将重要的AI大模型资料包括AI大模型入门学习思维导图、精品AI大模型学习书籍手册、视频教程、实战学习等录播视频免费分享出来。

一、全套AGI大模型学习路线

AI大模型时代的学习之旅:从基础到前沿,掌握人工智能的核心技能!

因篇幅有限,仅展示部分资料,需要点击文章最下方名片即可前往获取

二、640套AI大模型报告合集

这套包含640份报告的合集,涵盖了AI大模型的理论研究、技术实现、行业应用等多个方面。无论您是科研人员、工程师,还是对AI大模型感兴趣的爱好者,这套报告合集都将为您提供宝贵的信息和启示。

因篇幅有限,仅展示部分资料,需要点击文章最下方名片即可前往获

三、AI大模型经典PDF籍

随着人工智能技术的飞速发展,AI大模型已经成为了当今科技领域的一大热点。这些大型预训练模型,如GPT-3、BERT、XLNet等,以其强大的语言理解和生成能力,正在改变我们对人工智能的认识。 那以下这些PDF籍就是非常不错的学习资源。


因篇幅有限,仅展示部分资料,需要点击文章最下方名片即可前往获

四、AI大模型商业化落地方案

因篇幅有限,仅展示部分资料,需要点击文章最下方名片即可前往获

作为普通人,入局大模型时代需要持续学习和实践,不断提高自己的技能和认知水平,同时也需要有责任感和伦理意识,为人工智能的健康发展贡献力量

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/4/23 9:18:42

DDD碎片记录 01.落地到数据库设计

系统用例设计,分析系统需要完成的功能。分析系统的业务实体,在领域模型分析中采用类图的形式,每个类可以通过其属性来表述数据结构,又可以通过添加方法来描述对数据结构的处理。 因此在领域模型的设计过程中,即完成了对…

作者头像 李华
网站建设 2026/4/22 21:56:20

推荐汽车制造业拧紧工艺智能化解决方案有哪些?

拧紧工艺:汽车制造中的隐形守护者在当今汽车制造业的快节奏发展环境中,拧紧工艺系统作为连接关键零部件的隐形支柱,扮演着不可忽视的角色。想象一下,一辆汽车的发动机缸盖螺栓如果不精确拧紧,可能会导致密封失效&#…

作者头像 李华
网站建设 2026/4/18 8:27:03

基于深度学习YOLOv11的骑手佩戴头盔检测系统(YOLOv11+YOLO数据集+UI界面+登录注册界面+Python项目源码+模型)

一、项目介绍 本文介绍了一个基于YOLOv11目标检测算法的骑手佩戴头盔智能检测系统。该系统旨在对道路交通场景中的摩托车骑手进行实时监测与识别,核心功能是准确检测并区分三类目标:佩戴头盔的骑手(helmet)、未佩戴头盔的骑手&am…

作者头像 李华
网站建设 2026/4/20 10:38:19

基于微信小程序的城市公交查询系统

Spring Boot基于微信小程序的城市公交查询系统是一种现代化的城市公交信息服务解决方案。以下是对该系统的详细介绍: 一、系统背景与意义 随着城市化进程的加快和人口持续增长,城市公共交通系统面临着前所未有的挑战。传统的公交查询方式存在信息更新不及…

作者头像 李华
网站建设 2026/4/23 7:44:12

基于Hadoop的网购电脑行为分析系统

Spring Boot基于Hadoop的网购电脑行为分析系统是一个专为电商企业设计的解决方案,旨在通过大数据技术和Hadoop平台,对网购电脑的相关数据进行收集、存储、处理和分析,以深入了解消费者的网购电脑行为,进而优化营销策略和提升用户体…

作者头像 李华
网站建设 2026/4/17 16:38:48

最近在折腾工控项目的时候,发现不少同行在找汇川PLC的C#通讯方案。正好手头有个实战项目积累的源码库,今天挑几个关键实现点跟大家唠唠

C#汇川全系列上位机适配源码 C#上位机读写PLC案例,TCP通信,通讯部分封装成类,没有加密,都是源码,注释齐全,纯源码,此版本支持汇川全系列PLC的ModebusTCP通讯的读写操作。 C#上位机与汇川全系列P…

作者头像 李华