查看: 1208| 回复: 5
跳转到指定楼层
上一主题 下一主题
收起左侧

[自我提升] kafka dead letter queue里面的消息有什么作用吗

🔗
匿名用户-BOSC9  | 添加认证 | 2022-10-1 06:49:10 |倒序浏览

注册一亩三分地论坛,查看更多干货!

您需要 登录 才可以下载或查看附件。没有帐号?注册账号

x
楼主从网上搜了一堆资料,发现Kafka多次重试发送一个消息,但是始终不能成功的话,就会把这个消息放进dead letter queue。
可是就是找不到有什么地方讲到底怎么使用这个dead letter queue。消息放进去了就不管了吗?还是说这个队列是留作证据的,让Kafka知道这几个消息没有发送成功呢?

回复加米,谢谢!

上一篇:狗家因H1b转到海外分部需要慎重
下一篇:亚麻选组求建议 (Prime Video vs SPS)
全局:

评分

参与人数 1大米 +1 收起 理由
zzupupup + 1 很有用的信息!

查看全部评分

回复

使用道具 举报

地里匿名用户
🔗
匿名用户-ZSF3F  | 添加认证 | 2022-10-1 07:23:27 来自APP
dead letter queue是用来处理kafka ”正常”queue无法处理的消息,比如因为格式错误或type冲突引起exception的消息就被放到dead letter queue,怎么处理由你决定,可以人工处理,可以批处理某个类型,也可以完全不处理。

评分

参与人数 1大米 +1 收起 理由
zzupupup + 1 给你点个赞!

查看全部评分

回复

使用道具 举报

地里匿名用户
🔗
匿名用户-YL7XI  | 添加认证 | 2022-10-1 08:22:59
dlq可以提醒developer进行故障诊断,或者提供给用户额外的选项让他们进行处理的

评分

参与人数 1大米 +1 收起 理由
zzupupup + 1 给你点个赞!

查看全部评分

回复

使用道具 举报

全局:
好奇楼主会不会碰到我之前写的dlq的代码哈哈
回复

使用道具 举报

地里匿名用户
🔗
匿名用户-JZGYT  | 添加认证 | 2022-10-1 10:42:10
kafka自带是没有DLQ的吧?只要consumer poll了,那么offset就会被commit.
DLQ是别人自己实现的吧?所以要问怎么用的话,得看具体是哪个kafka library了。

评分

参与人数 1大米 +1 收起 理由
zzupupup + 1 给你点个赞!

查看全部评分

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册账号
职场达人
  • ↑ 本版用于讨论职场各种干货话题,闲聊请去🔗聊聊或者🔗匿名版
  • ❌ 本版严禁水贴,引战,发布广告,拉群,贴个人联系方式,扣分无警告
  • ☑ 求职、面经等去 🔗北美求职和 🔗回国求职大区,刷题和学习请去 🔗终身学习大区
  • ☑ 请去专版发布 🔗内推, 🔗招聘信息,和讨论 🔗创业内容
  • ☑ PIP / DevList/ Need Support 等话题也已开设 🔗专版

本版积分规则

>
快速回复 返回顶部 返回列表