lib/fluent/plugin/out_elasticsearch_dynamic.rb in fluent-plugin-elasticsearch-2.8.3 vs lib/fluent/plugin/out_elasticsearch_dynamic.rb in fluent-plugin-elasticsearch-2.8.4

@@ -158,10 +158,10 @@
             time = Time.parse record["@timestamp"]
           elsif record.has_key?(dynamic_conf['time_key'])
             time = Time.parse record[dynamic_conf['time_key']]
             record['@timestamp'] = record[dynamic_conf['time_key']] unless time_key_exclude_timestamp
           else
-            record.merge!({"@timestamp" => Time.at(time).to_datetime.to_s})
+            record.merge!({"@timestamp" => Time.at(time).iso8601(@time_precision)})
           end
         end
 
         if eval_or_val(dynamic_conf['logstash_format'])
           if eval_or_val(dynamic_conf['utc_index'])