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)