Hiya, During leader changes, we see short periods of message loss on some of our higher volume producers. I suspect that this is because it takes a couple of seconds for Zookeeper to notice and notify the producers of the metadata change. During this time, producer buffers can fill up and end up dropping some messages.
I’d like to do some troubleshooting. Is it possible to manually change the leadership of a single partition? I see here[1] that I can start a leadership election for a particular partition, but the JSON doesn’t show a way to choose the new leader of the partition. Thanks! -Andrew Otto [1] https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-Howtousethetool?.1