Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2805

RecordAccumulator request timeout not enforced when all brokers are gone

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9.0.0
    • Component/s: None
    • Labels:
      None

      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.

        Attachments

          Activity

            People

            • Assignee:
              mgharat Mayuresh Gharat
              Reporter:
              hachikuji Jason Gustafson
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: