spring cloud@streamlistener自定义错误处理程序

zour9fqk  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(453)

我正在使用springcloud来处理来自kafka的消息,但是我正在寻找如何实现errorhandler以在侦听器抛出异常时记录自定义消息的指南或示例。
示例代码如下:

@EnableBinding(Customer.class)
@EnableAutoConfiguration
public static class CustomerEventListner{

@StreamListener("customerloginEvent")
public void handleCustomerLoginEventListner() {
   // handle the message
}

默认情况下,如果未定义错误处理程序,则会执行defalt kafka日志记录:
错误消息:[afka-listener-1]o.s.kafka.listener.loggingerrorhandler:处理时出错:consumerrecord(主题=

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题