如何在错误处理程序中将 spring kafka 偏移到下一个?
How to offset spring kafka to next in error handler?
我正在使用 spring data 1.5.8 和 kafka 的手动 ack 模式。只有一个简单的ErrorHandler接口,handle方法有参数exception和consumerRecord,但是当json无法反序列化时抛出异常,如何设置偏移量到next呢?我需要省略消息,否则消费者会卡在那里
spring data 2.0引入ConsumerAwareErrorHandler,唯一的办法就是更新spring版本?
是的。你需要升级。当前版本为2 4.0或2.3.4.
我正在使用 spring data 1.5.8 和 kafka 的手动 ack 模式。只有一个简单的ErrorHandler接口,handle方法有参数exception和consumerRecord,但是当json无法反序列化时抛出异常,如何设置偏移量到next呢?我需要省略消息,否则消费者会卡在那里
spring data 2.0引入ConsumerAwareErrorHandler,唯一的办法就是更新spring版本?
是的。你需要升级。当前版本为2 4.0或2.3.4.