[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14506011#comment-14506011 ]
Jiangjie Qin commented on KAFKA-2138: ------------------------------------- [~junrao] [~jjkoshy] Do you think we should also check this into 0.8.2.2? > 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 > Attachments: KAFKA-2138.patch > > > 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)