Как зафиксировать смещение с помощью ConsumerAwareErrorHandler при использовании параллелизма?

Question

В случае ошибки интерфейс ConsumerAwareErrorHandler предоставляет ссылку на метод ConsumerRecord и Consumer in handle.Теперь после обработки ошибки мы можем либо зафиксировать смещение, либо проигнорировать.Но мне интересно, как он будет себя вести, когда мы используем более одного потока (ConcurrentKafkaListenerContainerFactory.setConcurrency).Если последняя запись вычеркнута по ошибке по предыдущей причине по другой причине, и мы фиксируем смещение для последней, но первая запись не удалась с ошибкой FATAL, и мы не должны были зафиксировать какое-либо смещение.

Я использую AckMode.COUNT в сочетании с! AckOnError

Answer 1

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

Разделы распределены по потокам.