spring-cloud-stream - Spring Cloud Stream Kafka 异常处理

Question

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

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

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

我的问题是如何

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

Answer 1

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

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