lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.19 vs lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.20

@@ -188,10 +188,10 @@
 
       # out_kafka is mainly for testing so don't need the performance unlike out_kafka_buffered.
       producer = @kafka.producer(@producer_opts)
 
       es.each do |time, record|
-        record = record.select{|key, value| key.present?}
+        record = record.select{|key, value| !key.nil? && !key.empty?}
         if @output_include_time
           if @time_format
             record['time'] = Time.at(time).strftime(@time_format)
           else
             record['time'] = time