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)