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

Merge branch 'master' into kafkaio-admin-offset-estimation

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

Annotations

1 warning

The logs for this run have expired and are no longer available.