Skip to main content

Re: KTable restoration

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
>

Comments