Spring云流Kafka异常处理

Question

我正在开发一个应用程序，在该应用程序中，事件会导致spring data repository保存数据；

Entity entity = entityRepository.save((Entity) event.getPayload());

此代码可以引发各种异常，如DataIntegrityViolationException（运行时异常）。

• 处理此类异常和
• 生成带有导致此错误的有效负载的消息
• 例外，
• 允许生产者采取操作。

Answer 1

将自定义错误处理程序添加到绑定的侦听器容器中...

@Bean
ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>> customizer() {
    return (container, dest, group) -> {
        if (group.equals("theOneIWant")) {
            container.setErrorHandler( ... );
        }
    };
}