如何处理camel交换机向Kafka end point.Kafka推送消息时的拒绝连接异常,可能会宕机,或者在推送过程中会宕机。请告诉我如何处理这种类型的情况,我尝试使用onException块它不工作
发布于 2020-04-28 11:20:45
您可以尝试这样做:
`
.doTry()
.to("kafka:....)
.endDoTry()
.doCatch(Exception.class)
.to("direct:handleTechnicalCommunicationError")
.end()`
直接编写一个分隔路由:handleTechnicalCommunicationError来处理此错误
https://stackoverflow.com/questions/52625396
复制相似问题