Skip to content

[KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition)#36834

Open
sjvanrossum wants to merge 7 commits intoapache:masterfrom
sjvanrossum:kafkaio-admin-offset-estimation
Open

[KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition)#36834
sjvanrossum wants to merge 7 commits intoapache:masterfrom
sjvanrossum:kafkaio-admin-offset-estimation

Commits

Commits on Dec 19, 2025

Commits on Dec 20, 2025

Commits on Dec 21, 2025