conduktor.io ↗

KIP-22 — Expose a Partitioner interface in the new producer

Accepted Producer

Exposes a Partitioner interface in the new Java producer, allowing custom partitioning logic to be injected via the partitioner.class configuration. The internal DefaultPartitioner (hash key, round-robin on null key) was not pluggable, preventing strategies like sticky partitioning or business-key-based routing without modifying application code to set partition manually.

Details

AuthorHarsha
StatusAccepted
JIRAKAFKA-2091
WikiView on Apache Wiki
Created2015-04-23
Last Modified2015-07-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.