The producer might get an error code if the leader of the partitions being reassigned also changes. However it should retry and succeed. Do you see a behavior that suggests otherwise?
On Sat, Nov 8, 2014 at 11:45 PM, Shlomi Hazan <[email protected]> wrote: > Hi All, > I recently had an issue producing from python where expanding a cluster > from 3 to 5 nodes and reassigning partitions forced me to restart the > producer b/c of KeyError thrown. > Is this situation handled by the Java producer automatically or need I do > something to have the java producer refresh itself to see the reassigned > partition layout and produce away ? > Shlomi >
