В нашем случае мы должны подтверждать каждое сообщение/запись Kafka, как только оно успешно обработано KafkaListener. Я думаю, что этого можно добиться с помощью AckMode.RECORD, а также AckMode.MANUAL_IMMEDIATE (при условии, что мы подтверждаем тот же поток прослушивателя, что и мы).
Какой режим акк лучше всего подходит для этого варианта использования?
Подробнее здесь: https://stackoverflow.com/questions/787 ... -immediate
