lib/phobos/producer.rb in phobos-2.0.1 vs lib/phobos/producer.rb in phobos-2.0.2

@@ -76,11 +76,11 @@
           producer_store[:kafka_client]
         end
 
         def create_sync_producer
           client = kafka_client || configure_kafka_client(Phobos.create_kafka_client)
-          sync_producer = client.producer(regular_configs)
+          sync_producer = client.producer(**regular_configs)
           if Phobos.config.producer_hash[:persistent_connections]
             producer_store[:sync_producer] = sync_producer
           end
           sync_producer
         end
@@ -107,10 +107,10 @@
           producer&.shutdown unless Phobos.config.producer_hash[:persistent_connections]
         end
 
         def create_async_producer
           client = kafka_client || configure_kafka_client(Phobos.create_kafka_client)
-          async_producer = client.async_producer(async_configs)
+          async_producer = client.async_producer(**async_configs)
           producer_store[:async_producer] = async_producer
         end
 
         def async_producer
           producer_store[:async_producer]