The remove fetcher log entry is normal under addition of partitions, since
they indicate that some leader changes have happened so brokers are closing
the fetchers to the old leaders.
I just realized that the console Producer does not have the
message.send.max.retries options yet. Could you file a JIRA for this and I
will followup to add this option? As for now you can hard modify the
default value from 3 to a larger number.
On Tue, Aug 27, 2013 at 12:37 PM, Rajasekar Elango