thanks :) On Thu, Apr 4, 2019 at 11:11 AM Dimitry Lvovsky <dlvov...@gmail.com> wrote:
> 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 > > >
