Kirk True created KAFKA-20188:
---------------------------------
Summary: Implement timeout/expiration for
OffsetsRequestManager.fetchOffsets()
Key: KAFKA-20188
URL: https://issues.apache.org/jira/browse/KAFKA-20188
Project: Kafka
Issue Type: Improvement
Components: clients, consumer
Affects Versions: 4.1.0, 4.0.0, 4.2.0
Reporter: Kirk True
Assignee: Kirk True
The implementation of {{fetchOffsets()}} does not currently take a timeout and
it appears that it retries in an attempt to fetch all the offsets for the given
partitions. In edge cases where one or more partitions continuously fails, this
can cause repeated fetches until resolved.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)