Skip to content

[KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform #20935

[KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform

[KafkaIO] Share size and offset estimators among ReadFromKafkaDoFn instances per PTransform #20935

Triggered via issue November 12, 2024 22:55
Status Skipped
Total duration 24s
Artifacts

beam_PreCommit_PythonLint.yml

on: issue_comment
Matrix: beam_PreCommit_PythonLint
Fit to window
Zoom out
Zoom in