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

Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

    XMLWordPrintableJSON

Details

    Description

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

      The error is:

      org.opentest4j.AssertionFailedError: Did not get valid assignment for partitions HashSet(topic1-2, topic1-4, topic-1, topic-0, topic1-5, topic1-1, topic1-0, topic1-3). Instead, got ArrayBuffer(Set(topic1-0, topic-0, topic-1), Set(), Set(topic1-1, topic1-5))
      	at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
      	at org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
      	at kafka.api.AbstractConsumerTest.validateGroupAssignment(AbstractConsumerTest.scala:286)
      	at kafka.api.PlaintextConsumerTest.runMultiConsumerSessionTimeoutTest(PlaintextConsumerTest.scala:1865)
      	at kafka.api.PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose(PlaintextConsumerTest.scala:1277)
      

      The logs include these lines:
       

      [2023-12-13 15:33:33,180] ERROR [Consumer clientId=ConsumerTestConsumer, groupId=my-test] GroupHeartbeatRequest failed due to error: INVALID_REQUEST (org.apache.kafka.clients.consumer.internals.HeartbeatRequestManager:376)
      [2023-12-13 15:33:33,180] ERROR [Consumer clientId=ConsumerTestConsumer, groupId=my-test] Member JQ_e0S5FTzKnYyStB3aBrQ with epoch 0 transitioned to FATAL state (org.apache.kafka.clients.consumer.internals.MembershipManagerImpl:456)
      [2023-12-13 15:33:33,212] ERROR [daemon-consumer-assignment]: Error due to (kafka.api.AbstractConsumerTest$ConsumerAssignmentPoller:139)
      org.apache.kafka.common.errors.InvalidRequestException: RebalanceTimeoutMs must be provided in first request.
      [2023-12-13 15:33:39,196] 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)
      [2023-12-13 15:33:39,200] 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

        Activity

          People

            phuctran Phuc Hong Tran
            kirktrue Kirk True
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: