diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py
index 283023049..0eb06b18d 100644
--- 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
index ed6863fa2..abd0cfe09 100644
--- 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()