openstack/deb-python-kafka
Code Issues Proposed changes

Drop bytes encoding of consumer group in consumer integration test

Browse Source
This commit is contained in:
Dana Powers
2015-12-10 18:52:44 -08:00
parent b528410818
commit 9da5e49331
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/test_consumer_integration.py
View File

@@ -525,7 +525,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
@kafka_versions("0.8.1", "0.8.1.1", "0.8.2.1")
def test_kafka_consumer__offset_commit_resume(self):
GROUP_ID = random_string(10).encode('utf-8')
GROUP_ID = random_string(10)
self.send_messages(0, range(0, 100))
self.send_messages(1, range(100, 200))