diff options
| -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) |