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

Fix PlaintextConsumerTest.testMaxPollIntervalMs

    XMLWordPrintableJSON

Details

    Description

      The integration test PlaintextConsumerTest.testMaxPollIntervalMs is failing when using the AsyncKafkaConsumer.

      The error is:

      org.opentest4j.AssertionFailedError: Timed out before expected rebalance completed
    at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
    at org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
    at kafka.api.AbstractConsumerTest.awaitRebalance(AbstractConsumerTest.scala:317)
    at kafka.api.PlaintextConsumerTest.testMaxPollIntervalMs(PlaintextConsumerTest.scala:194)

      The logs include this line:
       

      [2023-12-13 15:11:16,134] WARN [Consumer clientId=ConsumerTestConsumer, groupId=my-test] consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records. (org.apache.kafka.clients.consumer.internals.HeartbeatRequestManager:188)

       

      I don't know if that's related or not.

       

       

      Attachments

        Issue Links

          is caused by

          Sub-task - The sub-task of the issue KAFKA-16258 Stale member should trigger onPartitionsLost when leaving group

          • Critical - Crashes, loss of data, severe memory leak.
          • Resolved
          is duplicated by

          Test - A new unit, integration or system test. KAFKA-15993 Enable max poll integration tests that depend on callback invocation

          • Blocker - Blocks development and/or testing work, production could not run
          • Resolved
          relates to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-16104 Enable additional PlaintextConsumerTest tests for new consumer

          • Critical - Crashes, loss of data, severe memory leak.
          • Resolved

          Activity

            People

              lucasbru Lucas Brutschy
              kirktrue Kirk True
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: