[jira] [Created] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER

[Alyssa Huang (Jira)]

Alyssa Huang created KAFKA-16427:
------------------------------------

             Summary: KafkaConsumer#position() does not respect timeout when 
group protocol is CONSUMER
                 Key: KAFKA-16427
                 URL: https://issues.apache.org/jira/browse/KAFKA-16427
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 3.7.0
            Reporter: Alyssa Huang


When

`long position(TopicPartition partition, final Duration timeout);`

is called on an unknown topic partition (and auto creation is disabled), the 
method fails to adhere to the timeout supplied.

e.g. the following warning is logged continuously as metadata fetches are 
retried 
[2024-03-26 11:03:48,589] WARN [Consumer clientId=ConsumerTestConsumer, 
groupId=my-test] Error while fetching metadata with correlation id 200 : 
\{nonexistingTopic=UNKNOWN_TOPIC_OR_PARTITION} 
(org.apache.kafka.clients.NetworkClient:1313)



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