Skip to content

[KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn #11588

[KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn

[KafkaIO] Fix per-split metric updates for KafkaUnboundedReader and ReadFromKafkaDoFn #11588

Triggered via issue November 6, 2024 16:54
Status Skipped
Total duration 20s
Artifacts
Matrix: beam_PostCommit_Python_ValidatesContainer_Dataflow
Fit to window
Zoom out
Zoom in