Hi Kafka Dev Team, I would like you get your feedback about adding yet another method or API call to onPartitionsChange( ) to Partitioner Interface to get notify about partition changes upon metadata refresh.
This will allow custom logic (implementor of Partitioner) to be notified if partition ownership or partition online vs offline, or partition increase/decrease event happen and when changes were propagated to individual producer instance. Please note this is my first KIP and if process is not followed correctly, please do let me know. I will be more than happy to follow or correct something that I may have missed. Thanks in advance and looking forward to your feedback. Thanks, Bhavesh