lib/messaging/adapters/kafka.rb in messaging-3.8.2 vs lib/messaging/adapters/kafka.rb in messaging-4.0.0.pre

@@ -35,10 +35,10 @@
       # Internal: Setup a Ruby-Kafka client
       def create_kafka_client
         # We have a specific logger for Ruby-Kafka as it
         # is a bit more noisy than we would like.
         kafka_logger = Messaging.logger.dup.tap { |logger| logger.level = Config.kafka.log_level }
-        ::Kafka.new(**Config.kafka.client.to_h.merge(client_id: Config.app_name, logger: kafka_logger))
+       ::Kafka.new(**Config.kafka.client.to_h.merge(client_id: Config.app_name, logger: kafka_logger))
       end
 
       def self.register!
         return if Adapters.key? :kafka