Skip to content

Add deterministic redistribute sharding for KafkaIO read. - #36112

Merged
chamikaramj merged 19 commits into
apache:masterfrom
tomstepp:kafka-key
Sep 30, 2025
Merged

Add deterministic redistribute sharding for KafkaIO read.#36112
chamikaramj merged 19 commits into
apache:masterfrom
tomstepp:kafka-key

numBuckets as UnsignedInteger to reduce conversion overhead, and clar…

ebef848
Select commit
Loading
Failed to load commit list.
Sign in for the full log view

Annotations

7 warnings

The logs for this run have expired and are no longer available.