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

mac m1 docker 安装kafka和zookeeper

获取本地ip地址  ifconfig en0  

192.168.0.105.   下面的ip都会使用到

1、拉取镜像

docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka

2、启动容器 启动 zookeeper docker run -d --name zookeeper -p 2181:2181 映射

3、

启动 kafka

注意,kafka 依赖 zookeeper,启动 kafka 前需要先启动 zookeeper。 这边端口映射9092:9092 之前用19092:9092 装成功 消息一直发不了

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.0.105:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.31.35:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e TZ="Asia/Shanghai" wurstmeister/kafka 

4、生产者消息,消费者 消息

测试 kafka 生产与消费

进入 kafka 容器

docker exec -it kafka bash

cd /opt/kafka_2.13-2.8.1/bin

./kafka-console-producer.sh --broker-list 192.168.0.105:9092 --topic first-topic

然后另外新建一个窗口,消息者开启。然后上面发消息,下面看是否收到

./kafka-console-consumer.sh --bootstrap-server 192.168.0.105:9092 --topic first-topic --from-beginning

参考文章:https://www.cnblogs.com/chenweihao/p/17231176.html

报错一:Error while fetching metadata with correlation id 10 : {first-topic=LEADER_NOT_AVAIL

进入容器,然后vim /opt/kafka/config/server.properties

 

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

相关文章:

  • 宏观经济和风电预测误差分析(Matlab代码实现)
  • GO学习之 搜索引擎(ElasticSearch)
  • Sentinel —实时监控
  • 接口优化通用方案
  • 用Visual Studio 2022的.map文件来查看C++变量在内存中的布局情况
  • 使用代理突破浏览器IP限制
  • HuggingFace中的 Files and versions 如何优雅下载到本地?(Python requests,tqdm)
  • 三、原型模式
  • transformer实现词性标注
  • Java中异或操作和OTP算法
  • K8S最新版本集群部署(v1.28) + 容器引擎Docker部署(下)
  • 女子垒球运动的发展·垒球1号位
  • Debian 30 周年,生日快乐!
  • 字符串匹配的Rabin–Karp算法
  • 傅里叶变换(FFT)笔记存档
  • ELK安装、部署、调试 (二) ES的安装部署
  • Android 13 - Media框架(8)- MediaExtractor
  • Flutter 混合开发调试
  • C语言每日一练------(Day3)
  • 14、监测数据采集物联网应用开发步骤(10)
  • Linux禅道上修改Apache 和 MySQL 默认端口号
  • 操作教程|通过1Panel开源Linux面板快速安装DataEase
  • 机器学习策略——优化深度学习系统
  • ES6中Proxy和Proxy实例
  • UDP协议的重要知识点
  • QT6为工程添加资源文件,并在ui界面引用
  • Python小知识 - 如何使用Python的Flask框架快速开发Web应用
  • Flutter 项目结构文件
  • 未找到System.Runtime.InteropServices.Marshal.GetTypeFromCLSID(System.Guid) 方法错误
  • 人员位置管理,点亮矿山安全之路