You can detect state changes in your streaming app by implementing KafkaStreams.StateListener, and then registering that with your KafkaStreeams Object e.g new KafkaStreams(...).setStateListener();
Hope this helps. On Thu, Apr 4, 2019 at 10:52 AM Pierre Coquentin <pierre.coquen...@gmail.com> wrote: > Hi, > > We have a cache in a processor based on assigned partitions and when Kafka > revokes those partitions we would like to flush the cache. The method > punctuate is neet to do that except that as a client of Kafka stream, I am > not notified during a revoke. > I found the same question on StackOverflow > > https://stackoverflow.com/questions/51626089/kafka-streams-consumerrebalancelistener-implementation > but > nothing in Jira. Is it plan to develop this kind of feature? Or perhaps I > missed something? > Regards, > > Pierre >
