spring-cloud-stream kafka DLT 消息的消费者组名称 header

Question

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

Answer 1

您可以通过添加 ListenerContainerCustomizer @Bean.

来添加带有自定义 DeadLetterPublishingRecoverer 的自定义 SeekToCurrentErrorHandler

但是，如果您这样做，您应该在活页夹中禁用重试（设置 maxAttempts=1）并在活页夹中也禁用 DLT。

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

请向活页夹打开一个新功能请求，我认为添加 header 通常会有用。