Skip to content

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

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

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

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