Доступ к потребителю из ConsumerRebalanceListener в Spring Kafka

Для этого вам необходимо использовать реализацию ConsumerSeekAware из ваш целевой слушатель:

Первый вызывается при запуске контейнера; этот обратный вызов следует использовать при поиске в произвольное время после инициализации. Вы должны сохранить ссылку на обратный вызов; если вы используете один и тот же прослушиватель в нескольких контейнерах (или в ConcurrentMessageListenerContainer), вы должны сохранить обратный вызов в ThreadLocal или какой-либо другой структуре, на которую указывает поток прослушивателя.

При использовании группового управления второй метод вызывается при изменении назначений. Вы можете использовать этот метод, например, для установки начальных смещений для разделов, вызвав обратный вызов; вы должны использовать аргумент обратного вызова, а не тот, который передается в registerSeekCallback. Этот метод никогда не будет вызываться, если вы сами явно назначаете разделы; в этом случае используйте TopicPartitionInitialOffset.