Merge branch 'master' into kafka-v3-cicd

wbarnha · Aug 9, 2024 · 525e69d · 525e69d
2 parents 5b0cf3e + 31a6b92
commit 525e69d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py
@@ -220,6 +220,7 @@ def consumer_thread(i, group_id):
                 else:
                     sleep(1)
             assert time() < timeout, "timeout waiting for assignments"
+            sleep(0.25)
 
         info('Group stabilized; verifying assignment')
         output = kafka_admin_client.describe_consumer_groups(group_id_list)

diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
@@ -111,6 +111,7 @@ def consumer_thread(i):
                     logging.info('Rejoining: %s, generations: %s', rejoining, generations)
                     time.sleep(1)
             assert time.time() < timeout, "timeout waiting for assignments"
+            time.sleep(0.25)
 
         logging.info('Group stabilized; verifying assignment')
         group_assignment = set()