Multiply * 1000 to make correct nanosecond digit

Author: cosmo0920

lib/logstash/codecs/fluent.rb

@@ -52,7 +52,7 @@ def encode(event)
     # Fluentd cannot handle Array class value in forward protocol's tag.
     tag = forwardable_tag(event)
     epochtime = if @nanosecond_precision
-                  EventTime.new(event.timestamp.to_i, event.timestamp.usec)
+                  EventTime.new(event.timestamp.to_i, event.timestamp.usec * 1000)
                 else
                   event.timestamp.to_i
                 end

spec/codecs/fluent_spec.rb

@@ -70,7 +70,8 @@
   describe "event decoding with EventTime" do
 
     let(:tag)       { "mytag" }
-    let(:epochtime) { LogStash::Codecs::Fluent::EventTime.new(event.timestamp.to_i, event.timestamp.usec)  }
+    let(:epochtime) { LogStash::Codecs::Fluent::EventTime.new(event.timestamp.to_i,
+                                                              event.timestamp.usec * 1000)  }
     let(:data)      { LogStash::Util.normalize(event.to_hash) }
     let(:message) do
       @packer.pack([tag, epochtime, data.merge(LogStash::Event::TIMESTAMP => event.timestamp.to_iso8601)])