Kafka manual ackMode MANUAL_IMMEDIATE что если не подтвердить

Question

Я использую Spring KafKa, и я устанавливаю ackMode в MANUAL_IMMEDIATE

props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE);

. Сценарий таков, что по какой-то причине мое приложение не может подтвердить (acknowledgment.acknowledge()) и просто пропустить его без исключения.

1- Как настроить повторную попытку потребителя для пропущенного сообщения 2- Как настроить вызов функции после того, как максимальное число повторов, которое я настроил, достигло

Answer 1

См. документацию о SeekToCurrentErrorHandler s .

Когда слушатель выдает исключение, обработчик ошибок выполнит необходимые операции поиска и повторно извлечет запись.Вы можете установить количество попыток до отказа.

Существует также a DeadLetterPublishingRecoverer, который можно использовать для отправки неудачной записи в другую тему.