Jiangjie Qin created KAFKA-3388:
-----------------------------------

             Summary: Producer should only timeout a batch in the accumulator 
when metadata is missing.
                 Key: KAFKA-3388
                 URL: https://issues.apache.org/jira/browse/KAFKA-3388
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 0.9.0.1
            Reporter: Jiangjie Qin
            Priority: Blocker
             Fix For: 0.10.0.0

In KIP-19 we are reusing the request.timeout.ms to timeout the batches in the 
accumulator. We were intended to avoid the case that the batches sitting in the 
accumulator forever when topic metadata is missing.

Currently we are not checking if metadata is available or not when we timeout 
the batches in the accumulator (although the comments says we will check the 
metadata). This causes problem that once the previous batch hit a request 
timeout and got retried, all the subsequent batches will fail with timeout 
exception. We should only timeout the batches in the accumulator when the 
metadata of the partition is missing.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to