spring-cloud-stream kafka DLT消息消费组名头部

Question

我正在寻找解决方案，将消费者组名称作为标题添加到DLT消息。我在想DeadLetterPublishingRecoverer，但我找不到一种方法让它与spring-cloud-stream一起工作，而不是spring-kafka。

Answer 1

您可以通过添加ListenerContainerCustomizer @Bean来添加具有自定义DeadLetterPublishingRecoverer的自定义@Bean。

但是，如果这样做，您应该在绑定器中禁用重试(设置maxAttempts=1)，并在绑定器中禁用DLT。

这样，重试和DLT将由容器控制。

请打开一个新的功能请求到活页夹，我认为添加标题是一般有用的东西。