Sorry for reviving this old mailing list discussion. I'm facing a similar issue while running a load test with many small topics (100 topics) with 4 partitions each. There is also a Flink user who's facing the issue: https://issues.apache.org/jira/browse/FLINK-3066
Are you also writing into many topics at the same time? On Sat, Nov 14, 2015 at 4:07 PM, Sean Morris (semorris) <[email protected]> wrote: > I have suddenly starting having issues where when I am producing data I > occasionally get "NotLeaderForPartitionException: This server is not the > leader for that topic-partition". I am using Kafka 2.10-0.8.2.1 with the > new Producer class and no retries. If I add retries to the Producer > properties I am ending up with duplicates on the consumer side. > > Any idea what can be the cause of the NotLeaderForPartitionException? > > Thanks. > >
