source указан kafka topic,
при перезагрузки (а иногда и в процессе работы) сбрасывается оффсет на начало очереди
в логах:
INFO [PollableSourceRunner-KafkaSource-xxx] (org.apache.kafka.clients.consumer.internals.Fetcher.parseFetchedData:708) - Fetch offset 788136693 is out of range for partition Processedxxx-0, resetting offset
в чем может быть дело?
Retention подчистил данные в топике, и сохраненный оффсет уже неприменим, скорее всего
Обсуждают сегодня