Jiangjie Qin created KAFKA-2138:
-----------------------------------
Summary: KafkaProducer does not honor the retry backoff time.
Key: KAFKA-2138
URL: https://issues.apache.org/jira/browse/KAFKA-2138
Project: Kafka
Issue Type: Bug
Reporter: Jiangjie Qin
Assignee: Jiangjie Qin
Priority: Critical
In KafkaProducer, we only check the batch.lastAttemptMs in ready. But we are
not checking it in drain() as well.
The problem is that if we have two partitions both on the same node, suppose
Partition 1 should backoff while partition 2 should not. Currently partition
1's backoff time will be ignored.
We should check the lastAttemptMs in drain() as well.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
