openstack/deb-python-kafka
Code Issues Proposed changes

Dont use consumer_timeout_ms in kafka blocking test

Browse Source
This commit is contained in:
Dana Powers
2016-01-03 22:46:18 -08:00
parent 09358f9c82
commit c8226d030a
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
test/test_consumer_integration.py
View File

@@ -539,7 +539,6 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
enable_auto_commit=True,
auto_commit_interval_ms=100,
auto_offset_reset='earliest',
consumer_timeout_ms=100
)
# Grab the first 180 messages
@@ -556,14 +555,12 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
enable_auto_commit=True,
auto_commit_interval_ms=100,
auto_offset_reset='earliest',
consumer_timeout_ms=100
)
# 181-200
output_msgs2 = []
with self.assertRaises(StopIteration):
while True:
m = next(consumer2)
output_msgs2.append(m)
for _ in xrange(20):
m = next(consumer2)
output_msgs2.append(m)
self.assert_message_count(output_msgs2, 20)
#self.assertEqual(len(set(output_msgs1) & set(output_msgs2)), 15)
self.assertEqual(len(set(output_msgs1) | set(output_msgs2)), 200)