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.

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

close

void close()

Closes the partitioner

partition

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

Computes the partition for a record

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

results matching ""

    No results matching ""