Skip to content

[KafkaIO] Use consumer position and lag to estimate end offsets#39285

Merged
Abacn merged 2 commits into
apache:masterfrom
sjvanrossum:kafkaio-admin-offset-estimation
Jul 23, 2026
Merged

[KafkaIO] Use consumer position and lag to estimate end offsets#39285
Abacn merged 2 commits into
apache:masterfrom
sjvanrossum:kafkaio-admin-offset-estimation

Ensure that end offset estimate can't precede consumed offset

5946687
Select commit
Loading
Failed to load commit list.
Sign in for the full log view

Annotations

7 warnings
beam_PreCommit_Spotless (Run Spotless PreCommit)
succeeded Jul 23, 2026 in 1h 6m 59s