Skip to content

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

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

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

Triggered via issue November 13, 2024 12:20
Status Skipped
Total duration 1m 22s
Artifacts
Matrix: beam_PreCommit_Java_Hadoop_IO_Direct
Fit to window
Zoom out
Zoom in