Skip to content

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

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

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

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