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)