diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-02-06 11:58:54 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-02-09 10:34:19 -0800 |
| commit | 36316c12759f8e17131cbf33e3b3d1c7899a3385 (patch) | |
| tree | 8abec9e19d2f9742b5428c9e18c6e1b3e50b2596 | |
| parent | fb03c69544221a25e925b8c6af45e44ac6944b2a (diff) | |
| download | kafka-python-36316c12759f8e17131cbf33e3b3d1c7899a3385.tar.gz | |
Always use the initial partition list when hashing keys in KeyedProducer
| -rw-r--r-- | kafka/producer/keyed.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index fe5b056..36328ed 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -54,7 +54,7 @@ class KeyedProducer(Producer): self.partitioners[topic] = self.partitioner_class(self.client.get_partition_ids_for_topic(topic)) partitioner = self.partitioners[topic] - return partitioner.partition(key, self.client.get_partition_ids_for_topic(topic)) + return partitioner.partition(key) def send_messages(self,topic,key,*msg): partition = self._next_partition(topic, key) |