如何解决Camel Resilience4j断路器
我想使用resilience4j 框架进行容错。 我为 resilence4j 使用了骆驼默认配置。路由从 kafka 主题订阅消息并发送到 http 端点。
如果 http 端点关闭,它会尝试几次并进入 OPEN 状态。当 http 端点关闭时,它永远不会移动到半打开或关闭状态。如果我遗漏了什么,请帮助我。下面是我用于骆驼路线的代码片段。
from("kafka:{{ice.kafka.topics.goe.Trades}}?brokers=localhost:9092&autoOffsetReset=
{{ice.kafka.auto.offset.reset}}&autoCommitEnable=true&allowManualCommit=false")
.log("Kafka input ${body}")
.circuitBreaker().inheritErrorHandler(true)
.resilience4jConfiguration()
.timeoutEnabled(true).timeoutDuration(50000).writableStackTraceEnabled(true).end()
.log("before Resilience ${threadName}").log("${headers}")
.toD("http://localhost:8083/student/allstudent?httpMethod=GET")
.log("After Resilience ${threadName}")
;
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。