diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-10 16:24:32 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-10 18:37:03 -0800 |
| commit | d54980a2cd918f243e30ecc23a588fb597957e41 (patch) | |
| tree | 6d666d4832418863cf31ff186dab79805ba2b497 /kafka/producer/simple.py | |
| parent | 7a804224949315251b9183fbfa56282ced881244 (diff) | |
| download | kafka-python-d54980a2cd918f243e30ecc23a588fb597957e41.tar.gz | |
Drop kafka_bytestring
Diffstat (limited to 'kafka/producer/simple.py')
| -rw-r--r-- | kafka/producer/simple.py | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/kafka/producer/simple.py b/kafka/producer/simple.py index 13e60d9..d8647b6 100644 --- a/kafka/producer/simple.py +++ b/kafka/producer/simple.py @@ -46,9 +46,6 @@ class SimpleProducer(Producer): return next(self.partition_cycles[topic]) def send_messages(self, topic, *msg): - if not isinstance(topic, six.binary_type): - topic = topic.encode('utf-8') - partition = self._next_partition(topic) return super(SimpleProducer, self).send_messages( topic, partition, *msg |