Skip to content

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

Closed
sjvanrossum wants to merge 8 commits into
apache:masterfrom
sjvanrossum:kafkaio-admin-offset-estimation
Closed

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

Commits

Commits on Dec 19, 2025

Commits on Dec 20, 2025

Commits on Dec 21, 2025

Commits on Mar 13, 2026