kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Javier Holguera <javier.holgu...@gmail.com>
Subject Kafka Streams - StateRestoreListener called when new partitions assigned
Date Mon, 11 Nov 2019 20:16:21 GMT

I understand that the state store listener that can be set using
KafkaStreams.setGlobalStateRestoreListener will be invoked when the streams
app starts if it doesn't find the state locally (e.g., running on a
ephemeral docker container).

However, I wonder if the process happens as well if there is a rebalance
and the streams app gets assigned new partitions for which it doesn't have
state yet. Does the app go into the rebalancing state and stays there until
the state for those new partitions have been restored? Or does it go back
to running even if it hasn't happened yet?



  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message