Я использую @StreamListener для приема сообщения Kafka.
Я установил autoCommitOffset на false и autoCommitOnError на false.
Я отправка всех сообщений об ошибках в DLQ topi c, а также maxAttempt для сбоя. У меня возник вопрос при тестировании изменений.
Что произойдет, если я не подтверждаю использованное сообщение и не выдаю ошибку? Будет ли Кафка автоматически отправлять сообщение через какое-то время?
когда я выдаю ошибку, повторное воспроизведение запускается, и оно повторяется до тех пор, пока моя конфигурация maxAttempt и сообщение с ошибкой не отправится в DLQ topi c.
Let Я знаю, если Кафка поддерживает повторную попытку, если потребитель не выдаст ошибку и не подтвердит сообщение.