openstack/deb-python-kafka
Code Issues Proposed changes

Add 0.8.2.0 to some kafka_version tests

Browse Source
This commit is contained in:
Dana Powers
2015-01-14 12:58:41 -08:00
parent e87bff6eb3
commit 4e78199301
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/test_client_integration.py
View File

@@ -54,7 +54,7 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase):
# Offset Tests # # Offset Tests #
#################### ####################
@kafka_versions("0.8.1", "0.8.1.1") @kafka_versions("0.8.1", "0.8.1.1", "0.8.2.0")
def test_commit_fetch_offsets(self): def test_commit_fetch_offsets(self):
req = OffsetCommitRequest(self.topic, 0, 42, b"metadata") req = OffsetCommitRequest(self.topic, 0, 42, b"metadata")
(resp,) = self.client.send_offset_commit_request(b"group", [req]) (resp,) = self.client.send_offset_commit_request(b"group", [req])

4
test/test_consumer_integration.py
View File

@@ -257,7 +257,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
big_consumer.stop() big_consumer.stop()
@kafka_versions("0.8.1", "0.8.1.1") @kafka_versions("0.8.1", "0.8.1.1", "0.8.2.0")
def test_offset_behavior__resuming_behavior(self): def test_offset_behavior__resuming_behavior(self):
self.send_messages(0, range(0, 100)) self.send_messages(0, range(0, 100))
self.send_messages(1, range(100, 200)) self.send_messages(1, range(100, 200))
@@ -357,7 +357,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
self.assertEqual(len(messages), 5) self.assertEqual(len(messages), 5)
self.assertGreaterEqual(t.interval, TIMEOUT_MS / 1000.0 ) self.assertGreaterEqual(t.interval, TIMEOUT_MS / 1000.0 )
@kafka_versions("0.8.1", "0.8.1.1") @kafka_versions("0.8.1", "0.8.1.1", "0.8.2.0")
def test_kafka_consumer__offset_commit_resume(self): def test_kafka_consumer__offset_commit_resume(self):
GROUP_ID = random_string(10) GROUP_ID = random_string(10)