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

Triggered via issue November 6, 2024 15:38
Status Skipped
Total duration 19s
Artifacts
Matrix: beam_PostCommit_Python_ValidatesContainer_Dataflow
Fit to window
Zoom out
Zoom in