Skip to content

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

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

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

Triggered via issue October 25, 2024 14:19
@AbacnAbacn
commented on #32889 3cc2909
Status Skipped
Total duration 18s
Artifacts
Matrix: beam_PreCommit_Java_PVR_Prism_Loopback
Fit to window
Zoom out
Zoom in