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
| Author | Jacob Tomy |
| Status | Discussion |
| JIRA | KAFKA-15187 |
| Wiki | View on Apache Wiki |
| Created | 2023-07-15 |
| Last Modified | 2023-08-16 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.