Мое требование простое, но не может быть реализовано с использованием обычного потребителя, я хотел бы использовать записи из позиции последнего зафиксированного смещения при каждом опросе. Я имею в виду, что однажды после опроса набора записей, если я не зафиксировал смещение для этих записей вручную, я ожидал, что тот же набор записей будет возвращен мне в следующем опросе. Можно ли использовать простых потребителей Kafka ..? К вашему сведению, я уже настроил своего потребителя, а не автоматическую фиксацию.
Текущий обходной путь, который я использовал, заключается в том, что я вручную ищу смещение до последнего зафиксированного смещения перед каждым опросом, но оно добавляет ненужную обратную передачу и добавление задержки к сообщению обработки? есть ли у потребителя Kafka готовая конфигурация для достижения того, чего я ожидаю?