Skip to content

[KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position #11582

[KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position

[KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position #11582