diff --git a/gwcelery/kafka/bootsteps.py b/gwcelery/kafka/bootsteps.py
index 8f75c9445906be30b37c6bf9cbdad8560ffd1563..7973a0d86a6b3c474906d64ab531c8b31fc86612 100644
--- a/gwcelery/kafka/bootsteps.py
+++ b/gwcelery/kafka/bootsteps.py
@@ -35,7 +35,7 @@ class Producer(KafkaBootStep):
 
     name = 'Kafka Avro producer'
 
-    def __init__(self, parent, kafka=False, **kwargs):
+    def __init__(self, parent, **kwargs):
         super().__init__(parent, **kwargs)
         self.topic_url = parent.app.conf['scimma_broker_url'] + \
             parent.app.conf['scimma_topic_name']