我正在寻找解决方案，以添加消费者组名称作为标题dlt消息。我在考虑deadletterpublishingrecoverer，但我找不到一种方法让它与SpringCloudStream而不是SpringKafka一起工作。
p5fdfcr11#
您可以添加自定义的 SeekToCurrentErrorHandler 有一个习惯 DeadLetterPublishingRecoverer 通过添加ListenerContainerCustomizer @Bean .但是，如果这样做，则应该在活页夹（set）中禁用retry maxAttempts=1 )并在活页夹中禁用dlt。这样，重试和dlt由容器控制。请打开一个新的功能要求的活页夹，我认为添加该标题的东西，将是一般有用的。
SeekToCurrentErrorHandler
DeadLetterPublishingRecoverer
@Bean
maxAttempts=1
1条答案
按热度按时间p5fdfcr11#
您可以添加自定义的
SeekToCurrentErrorHandler有一个习惯DeadLetterPublishingRecoverer通过添加ListenerContainerCustomizer
@Bean.但是，如果这样做，则应该在活页夹（set）中禁用retry
maxAttempts=1)并在活页夹中禁用dlt。这样，重试和dlt由容器控制。
请打开一个新的功能要求的活页夹，我认为添加该标题的东西，将是一般有用的。