[
https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani updated KAFKA-2091:
------------------------------------------
Attachment: KAFKA-2091.patch
> Expose a Partitioner interface in the new producer
> --------------------------------------------------
>
> Key: KAFKA-2091
> URL: https://issues.apache.org/jira/browse/KAFKA-2091
> Project: Kafka
> Issue Type: Improvement
> Reporter: Jay Kreps
> Assignee: Sriharsha Chintalapani
> Attachments: KAFKA-2091.patch
>
>
> In the new producer you can pass in a key or hard code the partition as part
> of ProducerRecord.
> Internally we are using a class
> {code}
> class Partitioner {
> public int partition(String topic, byte[] key, Integer partition, Cluster
> cluster) {...}
> }
> {code}
> This class uses the specified partition if there is one; uses a hash of the
> key if there isn't a partition but there is a key; and simply chooses a
> partition round robin if there is neither a partition nor a key.
> However there are several partitioning strategies that could be useful that
> we don't support out of the box.
> An example would be having each producer periodically choose a random
> partition. This tends to be the most efficient since all data goes to one
> server and uses the fewest TCP connections, however it only produces good
> load balancing if there are many producers.
> Of course a user can do this now by just setting the partition manually, but
> that is a bit inconvenient if you need to do that across a bunch of apps
> since each will need to remember to set the partition every time.
> The idea would be to expose a configuration to set the partitioner
> implementation like
> {code}
> partitioner.class=org.apache.kafka.producer.DefaultPartitioner
> {code}
> This would default to the existing partitioner implementation.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
