Spring Cloud Stream Kafka 异常处理

Question

我正在开发一个应用程序，其中事件导致 spring 数据存储库保存数据；

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

此代码可以抛出各种异常，例如 DataIntegrityViolationException，它是运行时异常。

我的问题是如何

• 处理此类异常并
• generate a Message with Payload 导致此错误
• 例外，
• 允许生产者采取行动。

Answer 1

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

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