On further investigation we found that similar issue is already filed under
https://issues.apache.org/jira/browse/KAFKA-1351
To re validate we explicitly commented per message logs
in BrokerPartitionInfo.scala and DefaultEventHandler.scala.
The disabling of logs resulted in 5 times increase in pr
Dear Kafka Users,
We are using kafka-2.8.0-0.8.8 in our application development. The
application is running with two brokers each having one partition.
We are using high level api to send message over async producer. While
testing through put of our application we have observed that more than 60
