Remove bytes encoding for topic name in producer integration test

This commit is contained in:
Dana Powers
2015-12-10 18:52:18 -08:00
parent f86068a51a
commit b528410818

View File

@@ -166,7 +166,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase):
@kafka_versions("all")
def test_produce__new_topic_fails_with_reasonable_error(self):
new_topic = 'new_topic_{guid}'.format(guid = str(uuid.uuid4())).encode('utf-8')
new_topic = 'new_topic_{guid}'.format(guid = str(uuid.uuid4()))
producer = SimpleProducer(self.client, random_start=False)
# At first it doesn't exist