@@ -276,29 +276,29 @@ def test_delete_consumergroups(kafka_admin_client, kafka_consumer_factory, send_
276
276
277
277
@pytest .mark .skipif (env_kafka_version () < (1 , 1 ), reason = "Delete consumer groups requires broker >=1.1" )
278
278
def test_delete_consumergroups_with_errors (kafka_admin_client , kafka_consumer_factory , send_messages ):
279
- send_messages (range (0 , 100 ), partition = 0 )
280
- consumer1 = kafka_consumer_factory (group_id = "group1" )
281
- next (consumer1 )
282
- consumer1 .close ()
283
-
284
- consumer2 = kafka_consumer_factory (group_id = "group2" )
285
- next (consumer2 )
286
-
287
- consumergroups = {group_id for group_id , _ in kafka_admin_client .list_consumer_groups ()}
288
- assert "group1" in consumergroups
289
- assert "group2" in consumergroups
290
- assert "group3" not in consumergroups
291
-
292
- delete_results = {
293
- group_id : error
294
- for group_id , error in kafka_admin_client .delete_consumer_groups (["group1" , "group2" , "group3" ])
295
- }
296
-
297
- assert delete_results ["group1" ] == NoError
298
- assert delete_results ["group2" ] == NonEmptyGroupError
299
- assert delete_results ["group3" ] == GroupIdNotFoundError
300
-
301
- consumergroups = {group_id for group_id , _ in kafka_admin_client .list_consumer_groups ()}
302
- assert "group1" not in consumergroups
303
- assert "group2" in consumergroups
304
- assert "group3" not in consumergroups
279
+ send_messages (range (0 , 100 ), partition = 0 )
280
+ consumer1 = kafka_consumer_factory (group_id = "group1" )
281
+ next (consumer1 )
282
+ consumer1 .close ()
283
+
284
+ consumer2 = kafka_consumer_factory (group_id = "group2" )
285
+ next (consumer2 )
286
+
287
+ consumergroups = {group_id for group_id , _ in kafka_admin_client .list_consumer_groups ()}
288
+ assert "group1" in consumergroups
289
+ assert "group2" in consumergroups
290
+ assert "group3" not in consumergroups
291
+
292
+ delete_results = {
293
+ group_id : error
294
+ for group_id , error in kafka_admin_client .delete_consumer_groups (["group1" , "group2" , "group3" ])
295
+ }
296
+
297
+ assert delete_results ["group1" ] == NoError
298
+ assert delete_results ["group2" ] == NonEmptyGroupError
299
+ assert delete_results ["group3" ] == GroupIdNotFoundError
300
+
301
+ consumergroups = {group_id for group_id , _ in kafka_admin_client .list_consumer_groups ()}
302
+ assert "group1" not in consumergroups
303
+ assert "group2" in consumergroups
304
+ assert "group3" not in consumergroups
0 commit comments