We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7f1c795 commit 3380c5aCopy full SHA for 3380c5a
tests/common/__init__.py
@@ -38,9 +38,8 @@ def use_kraft():
38
39
def _get_consumer_generic(consumer_clazz, conf=None, **kwargs):
40
if use_group_protocol_consumer():
41
- if conf is None:
42
- conf = {}
43
- conf['group.protocol'] = 'consumer'
+ if conf is not None and 'group.id' in conf:
+ conf['group.protocol'] = 'consumer'
44
return consumer_clazz(conf, **kwargs)
45
46
0 commit comments