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
