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

System tests broken because consumer returns early without records

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.8.0
    • Component/s: consumer
    • Labels:
      None

      Description

      https://issues.apache.org/jira/browse/KAFKA-10866 added metadata to ConsumerRecords. We add metadata even when there are no records. As a result, we sometimes return early from KafkaConsumer#poll() with no records because FetchedRecords.isEmpty returns false if either metadata or records are available. This breaks system tests which rely on poll timeout, expecting records to be returned on every poll when there is no timeout.

        Attachments

          Activity

            People

            • Assignee:
              vvcephei John Roesler
              Reporter:
              rsivaram Rajini Sivaram
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: