Hi, In my application I have replicated internal changelog topics. >From time to time I get this exception and I am not able to figure out why.
[2016-12-05 11:05:10,635] ERROR Error sending record to topic test-stream-key-table-changelog (org.apache.kafka.streams.processor.internals.RecordCollector) org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. [2016-12-05 11:05:10,755] ERROR Error sending record to topic test-stream-key-table-changelog (org.apache.kafka.streams.processor.internals.RecordCollector) Please let me know what could be causing this. Thanks Sachin
