gpt4 book ai didi

spring - 带卡夫卡消费者的断路器

转载 作者:行者123 更新时间:2023-12-04 00:33:00 25 4
gpt4 key购买 nike

有没有办法实现 断路器图案 Spring 卡夫卡 基于消费者。我想知道在实现我的 Spring kafka 消费者时,如果基于某些外部系统处理数据失败并引发网络错误,是否可以停止消费记录。但是,如果网络问题得到解决,消费者应该再次正常处理。

最佳答案

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

例子

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

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

    您可以引用以下链接了解使用 的详细解决方案弹性4j 用于断路器实现 & Spring Cloud 流 消费者 .

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

    关于spring - 带卡夫卡消费者的断路器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48059981/

    25 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com