Guozhang Wang created KAFKA-1445:
------------------------------------
Summary: New Producer should send all partitions that have
non-empty batches when on of them is ready
Key: KAFKA-1445
URL: https://issues.apache.org/jira/browse/KAFKA-1445
Project: Kafka
Issue Type: Bug
Reporter: Guozhang Wang
Fix For: 0.9.0
One difference between the new producer and the old producer is that on the new
producer the linger time is per partition, instead of global. Therefore, when
the traffic is low, the sender will likely expire partitions one-by-one and
send lots of small request containing only a few partitions with a few data,
resulting largely increased request rate.
One solution of it would be to let senders select all partitions that have
non-empty batches when on of them is ready.
--
This message was sent by Atlassian JIRA
(v6.2#6252)