lib/semantic_logger/appender/kafka.rb in semantic_logger-4.1.0 vs lib/semantic_logger/appender/kafka.rb in semantic_logger-4.1.1

@@ -19,13 +19,13 @@
 #     # Set an optional client id in order to identify the client to Kafka:
 #     client_id: "my-application",
 #   )
 class SemanticLogger::Appender::Kafka < SemanticLogger::Subscriber
   attr_accessor :seed_brokers, :client_id, :connect_timeout, :socket_timeout,
-    :ssl_ca_cert, :ssl_client_cert, :ssl_client_cert_key,
-    :delivery_threshold, :delivery_interval,
-    :topic, :partition, :partition_key, :key
+                :ssl_ca_cert, :ssl_client_cert, :ssl_client_cert_key,
+                :delivery_threshold, :delivery_interval,
+                :topic, :partition, :partition_key, :key
 
   # Send log messages to Kafka in JSON format.
   #
   # Kafka Parameters:
   #
@@ -108,13 +108,13 @@
   #
   #   application: [String]
   #     Name of this application to appear in log messages.
   #     Default: SemanticLogger.application
   def initialize(seed_brokers:, client_id: 'semantic-logger', connect_timeout: nil, socket_timeout: nil,
-    ssl_ca_cert: nil, ssl_client_cert: nil, ssl_client_cert_key: nil,
-    topic: 'log_messages', partition: nil, partition_key: nil, key: nil,
-    delivery_threshold: 100, delivery_interval: 10,
-    level: nil, formatter: nil, filter: nil, application: nil, host: nil, &block)
+                 ssl_ca_cert: nil, ssl_client_cert: nil, ssl_client_cert_key: nil,
+                 topic: 'log_messages', partition: nil, partition_key: nil, key: nil,
+                 delivery_threshold: 100, delivery_interval: 10,
+                 level: nil, formatter: nil, filter: nil, application: nil, host: nil, &block)
 
     @seed_brokers        = seed_brokers
     @client_id           = @client_id
     @connect_timeout     = connect_timeout
     @socket_timeout      = socket_timeout