diff options
| -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() |