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
>
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
Post a Comment