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

kafka-python 消费者消费不到消息

排除步骤1:

使用group_id=”consumer_group_id_001“ 和 auto_offset_reset="earliest"

from kafka import KafkaConsumerconsumer = KafkaConsumer(bootstrap_servers=["dev-kafka01.test.xxx.cloud:9092"],enable_auto_commit=True, auto_commit_interval_ms=5000, group_id="test-consumer-group",auto_offset_reset="earliest")
consumer.subscribe(['add_topic'])
for msg in consumer:print(msg.key, msg.value)

排除步骤2:

   生产者发完消息后,在close中  先执行 producer.flush(),再执行 producer.close()

# -*- coding: utf-8 -*-from kafka import KafkaProducerproducer = KafkaProducer(bootstrap_servers=["dev-kafka01.test.xxx.cloud:9092"])
producer.send('add_topic', key=b'我是消息键',value=b'我是消息体,我是主角')
producer.flush()

排除步骤3:

使用offset 观看消息是否写到kafka中。

 排除步骤4:

 

 

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

相关文章:

  • 穿起“新架构”的舞鞋,跳一支金融数字化转型的华尔兹
  • SpringBoot 常用注解
  • k8s deployment创建pod流程图
  • C++ 逗号运算符
  • jdbc集成phoneix hbase
  • 16.遍历二叉树,线索二叉树
  • 电商平台按关键字搜索商品淘宝京东拼多多api接口PHP示例
  • 胖小酱之恰恰是什么
  • 豪越科技受邀出席2023中国算力大会
  • python脚本——批量将word文件转换成多张图片
  • FairyGUI编辑器的弹窗操作【插件】
  • Elasticsearch(十三)搜索---搜索匹配功能④--Constant Score查询、Function Score查询
  • 直播系统源码协议探索篇(二):网络套接字协议WebSocket
  • Windows 11 下使用 VMWare Workstation 17 Pro 新建 CentOS Stream 9 64位 虚拟机 并配置网络
  • 生信豆芽菜-缺氧评分的计算
  • C++:通过find/substr分割字符串
  • sql developer 连不上oracle数据库 报错 ORA-01031: insufficient privileges
  • LeetCode 面试题 01.07. 旋转矩阵
  • vue3 pdf、word等文件下载
  • 带你了解SpringBoot---开启Durid 监控
  • matlab 点云精配准(3)——Trimmed ICP
  • nodejs开发环境搭建示例
  • 网络安全(大厂)面试题
  • GC面临的困境,JVM是如何解决跨代引用的?
  • Qt下拉菜单
  • 考研C语言进阶题库——更新41-50题
  • JVM——JVM 垃圾回收
  • 浅析阿里云灵积(平台)模型服务
  • 使用 PyTorch 进行高效图像分割:第 1 部分
  • vellum (Discovering Houdini VellumⅡ柔体系统)学习笔记