lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.5.4 vs lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.5.5

@@ -160,17 +160,17 @@
           rescue StandardError => e
             log.warn "unexpected error during format record. Skip broken event:", :error => e.to_s, :error_class => e.class.to_s, :time => time, :record => record
             next
           end
 
-          log.on_trace { "message will send to #{topic} with partition_key: #{partition_key}, partition: #{partition}, message_key: #{message_key} and value: #{record_buf}." }
+          log.trace { "message will send to #{topic} with partition_key: #{partition_key}, partition: #{partition}, message_key: #{message_key} and value: #{record_buf}." }
           messages += 1
 
           producer.produce(record_buf, message_key, partition, partition_key)
         }
 
         if messages > 0
-          log.trace { "#{messages} messages send." }
+          log.debug { "#{messages} messages send." }
           producer.deliver_messages
         end
       end
     rescue Exception => e
       log.warn "Send exception occurred: #{e}"