diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-07 16:27:06 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-07 16:27:06 -0800 |
| commit | 1813d7d21ed1d9e76d9078a2c70a7657e8c18d07 (patch) | |
| tree | 309db0625956cc234257acdbb7836630060bcfed | |
| parent | c22473952b4094ee69e67cfb1a864ef2bdfe155e (diff) | |
| download | kafka-python-1813d7d21ed1d9e76d9078a2c70a7657e8c18d07.tar.gz | |
Fix integration test that requires consumer group
| -rw-r--r-- | test/test_consumer_integration.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index 9473691..f04a1d1 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -605,8 +605,11 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): # Start a consumer. FetchResponse_v3 should always include at least 1 # full msg, so by setting fetch_max_bytes=1 we must get 1 msg at a time + group = 'test-kafka-consumer-max-bytes-one-msg-' + random_string(5) consumer = self.kafka_consumer( - auto_offset_reset='earliest', fetch_max_bytes=1) + group_id=group, + auto_offset_reset='earliest', + fetch_max_bytes=1) fetched_msgs = [] # A bit hacky, but we need this in order for message count to be exact consumer._coordinator.ensure_active_group() |