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

@@ -65,10 +65,10 @@
       listeners_config = fetch_configuration(configuration)
       @config.listeners += listeners_config.listeners
     end
 
     def create_kafka_client
-      Kafka.new(config.kafka.to_hash.merge(logger: @ruby_kafka_logger))
+      Kafka.new(**config.kafka.to_hash.merge(logger: @ruby_kafka_logger))
     end
 
     def create_exponential_backoff(backoff_config = nil)
       backoff_config ||= Phobos.config.backoff.to_hash
       min = backoff_config[:min_ms] / 1000.0