【发布时间】：2020-11-02 19:08:30
【问题描述】：
我正在寻找将消费者组名称作为标头添加到 DLT 消息的解决方案。我在考虑 DeadLetterPublishingRecoverer 但我找不到一种方法让它与 spring-cloud-stream 而不是 spring-kafka 一起工作。
【问题讨论】：
标签： apache-kafka spring-kafka spring-cloud-stream
【发布时间】：2020-11-02 19:08:30
【问题描述】：
您可以通过添加ListenerContainerCustomizer @Bean 来添加自定义SeekToCurrentErrorHandler 和自定义DeadLetterPublishingRecoverer。
但是，如果您这样做，您应该在活页夹中禁用重试（设置maxAttempts=1）并在活页夹中禁用 DLT。
这样重试和 DLT 由容器控制。
请向活页夹打开一个新功能请求，我认为添加该标头通常会很有用。
【讨论】：