diff --git a/gwcelery/kafka/bootsteps.py b/gwcelery/kafka/bootsteps.py
index f9a86e229c7e1183ef1d92c5ca9aaece5875054c..2dace3c1097b84df1a759fa6a98af38dfa01e8a8 100644
--- a/gwcelery/kafka/bootsteps.py
+++ b/gwcelery/kafka/bootsteps.py
@@ -20,6 +20,7 @@ class KafkaBootStep(bootsteps.ConsumerStep):
     """
 
     def __init__(self, parent, kafka=False, **kwargs):
+        super().__init__(parent, **kwargs)
         self.enabled = bool(kafka)
 
     def start(self, parent):