Partitioner Contract — Partitioning Strategy

Partitioner is the contract of partitioners (aka partitioning strategies) that can compute the partition for a producer record.

Partitioner is also a Configurable that can be created by reflection and need to take configuration parameters.

DefaultPartitioner is the one and only known implementation of the Partitioner Contract in Apache Kafka.
Table 1. Partitioner Contract
Method Description


void close()

Closes the partitioner


int partition(
  String topic,
  Object key,
  byte[] keyBytes,
  Object value,
  byte[] valueBytes,
  Cluster cluster)

Computes the partition ID for a record (described by a topic, a key, a value, the serialized key and value, and the Cluster metadata)

Used when KafkaProducer is requested to compute the partition for a ProducerRecord

results matching ""

    No results matching ""