Set group_id for testingdefault_no_consumer_group

1 files changed, 2 insertions, 0 deletions

diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
index 9d9be60..885ae83 100644
--- a/test/test_consumer_group.py
+++ b/test/test_consumer_group.py
@@ -54,12 +54,14 @@ def test_group(kafka_broker, topic):
     stop = {}
     threads = {}
     messages = collections.defaultdict(list)
+    group_id = 'test-group-' + random_string(6)
     def consumer_thread(i):
         assert i not in consumers
         assert i not in stop
         stop[i] = threading.Event()
         consumers[i] = KafkaConsumer(topic,
                                      bootstrap_servers=connect_str,
+                                     group_id=group_id,
                                      heartbeat_interval_ms=500)
         while not stop[i].is_set():
             for tp, records in six.itervalues(consumers[i].poll(100)):