При использовании spring-kafka Acknowledgment
- это абстракция над подробным потребительским API для фиксации смещений.
При вызове acknowledgement.acknowledge()
; действие зависит от конфигурации. При AckMode.MANUAL
фиксация ставится в очередь для последующей обработки потребителем; с MANUAL_IMMEDIATE
, commitSync()
(по умолчанию или asyn c, в зависимости от конфигурации) вызывается немедленно.