21
21
from confluent_kafka .error import ConsumeError
22
22
from confluent_kafka import ConsumerGroupState , TopicCollection , ConsumerGroupType
23
23
24
- from tests .common import TestUtils
25
-
26
24
topic_prefix = "test-topic"
27
25
28
26
@@ -37,7 +35,7 @@ def consume_messages(sasl_cluster, group_id, group_protocol, topic, num_messages
37
35
'on_commit' : verify_commit_result ,
38
36
'auto.offset.reset' : 'earliest' }
39
37
40
- if group_protocol == 'classic' :
38
+ if group_protocol == 'classic' :
41
39
conf ['session.timeout.ms' ] = 6000
42
40
43
41
consumer = sasl_cluster .consumer (conf )
@@ -186,7 +184,7 @@ def verify_describe_groups(cluster, admin_client, topic):
186
184
# Delete group
187
185
perform_admin_operation_sync (admin_client .delete_consumer_groups , [group ], request_timeout = 10 )
188
186
189
- consumer_group = 'test-group-consumer'
187
+ consumer_group = 'test-group-consumer'
190
188
191
189
consume_messages (cluster , consumer_group , 'consumer' , topic , 2 )
192
190
@@ -205,6 +203,7 @@ def verify_describe_groups(cluster, admin_client, topic):
205
203
# Delete group
206
204
perform_admin_operation_sync (admin_client .delete_consumer_groups , [consumer_group ], request_timeout = 10 )
207
205
206
+
208
207
def verify_describe_cluster (admin_client ):
209
208
desc = verify_provided_describe_for_authorized_operations (admin_client ,
210
209
admin_client .describe_cluster ,
0 commit comments