[KafkaIO] Fix concurrent consumer bug in KafkaIOIT#34711

Closed

sjvanrossum wants to merge 1 commit intoapache:masterfrom

sjvanrossum:kafkaio-integration-test-fix

Commits on Apr 22, 2025

Call cancelIfTimeouted in roundtripElements to shutdown lingering pipelines
sjvanrossum
committed