Skip to content

Commit 55d7f08

Browse files
committed
Protocol->group_protocol
1 parent 94a9df0 commit 55d7f08

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

tests/integration/admin/test_describe_consumer_groups_compatability.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,12 @@
1919
topic_prefix = "test-topic"
2020

2121

22-
def create_consumers(kafka_cluster, topic, group_id, client_id, Protocol):
22+
def create_consumers(kafka_cluster, topic, group_id, client_id, group_protocol):
2323
conf = {'group.id': group_id,
2424
'client.id': client_id,
25-
'group.protocol': Protocol,
25+
'group.protocol': group_protocol,
2626
'enable.auto.commit': False,
27-
'auto.offset.reset': 'earliest',
28-
'debug': 'all'}
27+
'auto.offset.reset': 'earliest'}
2928
consumer = kafka_cluster.consumer(conf)
3029
consumer.subscribe([topic])
3130
consumer.poll(10)

0 commit comments

Comments
 (0)