kafka_consumer: bound and refine estimated_consumer_lag#24167

Open

piochelepiotr wants to merge 12 commits into

pwolski/kafka-consumer-lag-time-caps

Commits on Jun 25, 2026

kafka_consumer: fetch low watermark offsets once and share them

piochelepiotr
and
claude
committed
kafka_consumer: reuse _fetch_earliest_offsets instead of a parallel fetch

piochelepiotr
and
claude
committed
kafka_consumer: use low_watermark_offsets directly in topic metadata

piochelepiotr
and
claude
committed
kafka_consumer: address review feedback on lag bounding

piochelepiotr
and
claude
committed
kafka_consumer: trim comments to a single note on the extrapolation cap

piochelepiotr
and
claude
committed
kafka_consumer: move extrapolation-cap comment to the clamp line

piochelepiotr
and
claude
committed
kafka_consumer: reuse fetched topic partitions in topic metadata collection

piochelepiotr
and
claude
committed
kafka_consumer: satisfy ruff formatting for collect_all_metadata call

piochelepiotr
and
claude
committed