Hi team, I'm working on a long run application, which uses the Kafka Consumer API to poll messages from a given topic and partition. I'm assigning the topic and partition manually by using consumer.assign() API and polling messages by using consumer.poll().
One common scenario for my application is that certain partitions could be removed outside of my application and my application needs to know one partition has been removed to stop processing that partition. My question is that is there any way to get the removal information when I do consumer.assign() or consumer.poll() or any APIs that I can use? Thanks for your help!
