I noticed the following error during the startup logs, but otherwise Kafka stream is working fine.
Could you please let me know in what circumstances I would get this error? Bing AI suggests that there could have some changes to the topic data. In fact, the change has been done to Kafka Stream Processor to fetch the State Store out Processor Context instead of injecting it.
o.a.k.s.p.i.StoreChangelogReader : stream-thread xxx Encountered org.apache.kafka.clients.consumer.OffsetOutOfRangeException fetching records from restore consumer for partitions [changelog], it is likely that the consumer’s position has fallen out of the topic partition offset range because the topic was truncated or compacted on the broker, marking the corresponding tasks as corrupted and re-initializing it later.