Skip to content

[KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader - #39830

Open
sjvanrossum wants to merge 2 commits into
apache:masterfrom
sjvanrossum:kafkaio-offset-estimate-unbounded-reader
Open

[KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader#39830
sjvanrossum wants to merge 2 commits into
apache:masterfrom
sjvanrossum:kafkaio-offset-estimate-unbounded-reader

Replace broken synchronized reads/writes with atomic reads/writes

d9b6b79
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
beam_PreCommit_Java_Examples_Dataflow (Run Java_Examples_Dataflow PreCommit)
succeeded Aug 20, 2026 in 35m 8s