Apache Camel Kafka 异常处理

Question

如何处理连接拒绝异常，同时将骆驼交换中的消息推送到 Kafka 端点。Kafka可能会关闭，或者在此过程中会关闭。请帮助我如何处理此类情况 我尝试使用异常块它不起作用

Answer 1

你可以试试这个：

'

.doTry()
.to("kafka:....)
.endDoTry()
.doCatch(Exception.class)
.to("direct:handleTechnicalCommunicationError")
.end()

'

编写分离路由 直接：句柄技术通信错误处理此错误