我正在使用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(主题=
暂无答案!
目前还没有任何答案,快来回答吧!