Kafka Producer Partitioner Arayüzü

Giriş

Şu satırı dahil ederiz

import org.apache.kafka.clients.producer.Partitioner;

Açıklaması şöyle

computes the partition for the given record. If the partition is specified in the ProducerRecord, then the partitioner will return the same, otherwise, it will choose a partition for the message key based on the partitioning strategy (Round Robin, Hash Key, or Custom Partitioning). org.apache.kafka.clients.producer.internals.DefaultPartitioner, org.apache.kafka.clients.producer.RoundRobinPartitioner, org.apache.kafka.clients.producer.UniformStickyPartitioner, 

org.apache.kafka.clients.producer.Partitioner (Inteface)

Şeklen şöyle

Algoritma şöyle