RdKafka\TopicConf::setPartitioner

(PECL rdkafka >= 0.9.1)

RdKafka\TopicConf::setPartitioner — Set partitioner

Description

public RdKafka\TopicConf::setPartitioner(integer $partitioner): void

Set the partitioner to use for routing messages to partitions based on keys.

Parameters

partitioner (integer)

Must be one of the RD_KAFKA_MSG_PARTITIONER_* constants.