Skip to content
Back to pull request #32558

KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers. #13552

Sign in to view logs

KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers.

KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers. #13552

Annotations

2 warnings

beam_PreCommit_Java_Examples_Dataflow_Java21 (Run Java_Examples_Dataflow_Java21 PreCommit)

beam_PreCommit_Java_Examples_Dataflow_Java21 (Run Java_Examples_Dataflow_Java21 PreCommit)
succeeded Oct 2, 2024 in 35m 34s