У нас есть сценарий использования, при котором кэш может не заполняться время от времени. Мне нужен способ проинструктировать потребителя Kstream не фиксировать смещение при (cachePoplulated == false). Идея состоит в том, чтобы запустить перезагрузку кеша и попробовать повторную обработку сообщения от kafka. Как мы можем этого добиться.