[KAFKA-2805] RecordAccumulator request timeout not enforced when all brokers are gone

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Mayuresh Gharat
• Reporter: Jason Gustafson
• Created: 11/Nov/15 01:51
• Updated: 12/Nov/15 02:42
• Resolved: 12/Nov/15 02:42

Description

When no brokers are left in the cluster, the producer seems not to enforce the request timeout as expected.

From the user mailing list, the null check in batch expiration in RecordAccumulator seems questionable: https://github.com/apache/kafka/blob/ae5a5d7c08bb634576a414f6f2864c5b8a7e58a3/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java#L220.

If this is correct behavior, it is probably worthwhile clarifying the purpose of the check in a comment.