Yes, since Kafka 3.8, there is a so called "state updated thread".
https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java#L183 -Matthias On 4/17/25 6:58 AM, Chad Preisler wrote:
In the latest version of Kafka Streams does KTable restoration happen in its own thread? Can you point me to where that happens in the code base? Thanks, Chad
