File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -42,18 +42,18 @@ def _update_conf_group_protocol(conf=None):
42
42
43
43
44
44
class TestConsumer (Consumer ):
45
- def __init__ (self , conf , ** kwargs ):
45
+ def __init__ (self , conf = None , ** kwargs ):
46
46
_update_conf_group_protocol (conf )
47
47
super (TestConsumer , self ).__init__ (conf , ** kwargs )
48
48
49
49
50
50
class TestDeserializingConsumer (DeserializingConsumer ):
51
- def __init__ (self , conf , ** kwargs ):
51
+ def __init__ (self , conf = None , ** kwargs ):
52
52
_update_conf_group_protocol (conf )
53
53
super (TestDeserializingConsumer , self ).__init__ (conf , ** kwargs )
54
54
55
55
56
56
class TestAvroConsumer (AvroConsumer ):
57
- def __init__ (self , conf , ** kwargs ):
57
+ def __init__ (self , conf = None , ** kwargs ):
58
58
_update_conf_group_protocol (conf )
59
59
super (TestAvroConsumer , self ).__init__ (conf , ** kwargs )
You can’t perform that action at this time.
0 commit comments