conduktor.io ↗

KIP-953 — partition method to be overloaded to accept headers as well.

Discussion Producer

Adds an overloaded Partitioner#partition() method that includes the record's Headers, with a default implementation delegating to the key/value-only variant. Users who need to route records based on header values (e.g., priority routing) previously had to embed routing hints in the key or value, coupling business logic to the partitioning concern.

Details

AuthorJacob Tomy
StatusDiscussion
JIRAKAFKA-15187
WikiView on Apache Wiki
Created2023-07-15
Last Modified2023-08-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.