David Jacot created KAFKA-15080: ----------------------------------- Summary: Fetcher's lag never set when partition is idle Key: KAFKA-15080 URL: https://issues.apache.org/jira/browse/KAFKA-15080 Project: Kafka Issue Type: Bug Reporter: David Jacot Assignee: David Jacot
The PartitionFetchState's lag field is set to None when the state is created and it is updated when bytes are received for a partition. For idle partitions (newly created or not), the lag is never updated because `validBytes > 0` is never true. As a side effect, the partition is considered out-of-sync and could be incorrectly throttled. -- This message was sent by Atlassian Jira (v8.20.10#820010)