Заголовок имени группы потребителей для сообщения DLT spring-cloud-stream kafka

Question

Я ищу решение для добавления имени группы потребителей в качестве заголовка сообщения DLT. Я думал о DeadLetterPublishingRecoverer, но не могу найти способ заставить его работать с spring-cloud-stream вместо spring-kafka.

Answer 1

Вы можете добавить настраиваемый SeekToCurrentErrorHandler с настраиваемым DeadLetterPublishingRecoverer, добавив ListenerContainerCustomizer @Bean.

Однако, если вы это сделаете, вы должны отключить повторную попытку в подшивке (установить maxAttempts=1) и отключите DLT в связывании.

Таким образом, повторные попытки и DLT будут управляться контейнером.

Пожалуйста, откройте новый запрос функции в связывателе, я думаю, добавив это заголовок - это то, что обычно может быть полезно.