Function mz_storage::source::kafka::responsible_for_pid

fn responsible_for_pid(config: &RawSourceCreationConfig, pid: i32) -> bool

Computes whether this worker is responsible for consuming a partition. It assigns partitions to workers in a round-robin fashion, starting at an arbitrary worker based on the hash of the source id.