You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/03/26 18:13:00 UTC

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

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)