hi all,
we have HDP cluster - 2.6.4 with ambari 2.6.1 version
we have 3 kafka brokers with version 10.1
we saw in the /var/log/kafka/server.log many errors messages as :
in this example we have 6601 errors lines about - This server is not the leader for that topic-partition
grep "This server is not the leader for that topic-partition" server.log | wc -l
6601
example
[2019-01-06 14:56:53,312] ERROR [ReplicaFetcherThread-0-1011], Error for partition [topic1-example,34] to broker 1011:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
Michael-Bronson