[jira] [Created] (KAFKA-20315) Add test for single in-flight poll event logic in async/share consumer

["Lianet Magrans (Jira)" <ji...@apache.org>]

Lianet Magrans created KAFKA-20315:
--------------------------------------

             Summary: Add test for single in-flight poll event logic in async/share consumer
                 Key: KAFKA-20315
                 URL: https://issues.apache.org/jira/browse/KAFKA-20315
             Project: Kafka
          Issue Type: Test
          Components: clients, consumer
            Reporter: Lianet Magrans


The async and share consumer send a single poll event to the background when there is a call to consumer.poll. Even though there may be continuous calls to poll (triggered internally from the do-while within consumer.poll, or externally if the app continously calls consumer.poll), the intention is to not generate a new poll event as long as the inflight hasn't completed or expired.

New event created here only:

https://github.com/apache/kafka/blob/2f2d9b0172ec6bfee6d332ff8b7cd39f2660a964/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L903

Seems there is no unit test coverage for inflight management, which should be helpful to catch regressions (if by mistake we revert to sending too many poll events). 

Found this test gap while reviewing the changes for ShareConsumer https://github.com/apache/kafka/pull/21757#pullrequestreview-3954153888



--
This message was sent by Atlassian Jira
(v8.20.10#820010)