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

@@ -140,11 +140,11 @@
       connect_timeout:     connect_timeout,
       socket_timeout:      socket_timeout,
       ssl_ca_cert:         ssl_ca_cert,
       ssl_client_cert:     ssl_client_cert,
       ssl_client_cert_key: ssl_client_cert_key,
-      logger:              SemanticLogger::Processor.logger.clone
+      logger:              logger
     )
 
     @producer = @kafka.async_producer(
       delivery_threshold: delivery_threshold,
       delivery_interval:  delivery_interval
@@ -158,11 +158,9 @@
     @kafka = nil
   end
 
   # Forward log messages to Kafka producer thread.
   def log(log)
-    return false unless should_log?(log)
-
     json = formatter.call(log, self)
     @producer.produce(json, topic: topic, partition: partition, partition_key: partition_key, key: key)
   end
 
   # Use JSON Formatter by default.