Merge pull request #47 from RedHatInsights/fix_producer_config

Clean up the configuration before using it on producer

ccx_messaging/publishers/data_pipeline_publisher.py

@@ -21,6 +21,7 @@
 from kafka import KafkaProducer
 
 from ccx_messaging.error import CCXMessagingError
+from ccx_messaging.utils.kafka_config import producer_config
 
 LOG = logging.getLogger(__name__)
 
@@ -43,7 +44,9 @@ def __init__(self, outgoing_topic, bootstrap_servers, **kwargs):
         if self.topic is None:
             raise KeyError("outgoing_topic")
 
-        self.producer = KafkaProducer(bootstrap_servers=self.bootstrap_servers, **kwargs)
+        self.producer = KafkaProducer(
+            bootstrap_servers=self.bootstrap_servers, **producer_config(kwargs)
+        )
         LOG.info("Producing to topic '%s' on brokers %s", self.topic, self.bootstrap_servers)
         self.outdata_schema_version = 2