Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >问答首页 >卡夫卡用户断路器

卡夫卡用户断路器
EN

Stack Overflow用户
提问于 2018-01-02 03:16:41
回答 2查看 9.4K关注 0票数 6

有没有一种方法来实现一个断路器模式弹簧卡夫卡的基础上的消费者。我想知道,在实现我的Spring用户时,如果基于某个外部系统处理数据失败并引发网络错误,是否有可能停止使用记录。然而,如果网络问题得到解决,消费者应该再次正常处理。

EN

回答 2

Stack Overflow用户

发布于 2020-02-17 06:43:35

如果您想在下游服务或DB关闭时停止使用消息,则可以引用此解决方案。

示例

  • 消费者呼叫服务A
  • 服务A正在调用外部HTTP服务B
  • 当外部服务B关闭时,您想要设置断路器

在这种情况下,您可以在服务A上设置断路器,当外部服务B关闭时,这个电路就会打开。然后,在此断路器的状态转换时,调用您的侦听器/绑定(如果您使用的是spring云流)来停止/暂停使用者。因此,您的消息将停留在队列/主题上,直到断路器再次关闭&您不必死信消息或将它们放入错误队列/主题。

您可以参考下面的链接获得详细的解决方案,该解决方案使用Resilience4j 进行断路器实现,用于消费

https://dublincoders.com/circuit-breaker-kafka/

票数 7
EN

Stack Overflow用户

发布于 2018-05-31 11:30:28

重试与死信队列(DLQ)是一个很好的模式处理消费者的失败,断路器模式是很好的处理生产者的问题。

票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/48059981

复制
相关文章

相似问题

添加站长 进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

扫码加入开发者社群
关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例

扫码关注腾讯云开发者公众号
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
查看详情【社区公告】 技术创作特训营有奖征文