lib/logstash/codecs/avro.rb in logstash-codec-avro-0.1.3 vs lib/logstash/codecs/avro.rb in logstash-codec-avro-0.1.4

@@ -38,8 +38,8 @@
   def encode(event)
     dw = Avro::IO::DatumWriter.new(@schema)
     buffer = StringIO.new
     encoder = Avro::IO::BinaryEncoder.new(buffer)
     dw.write(event.to_hash, encoder)
-    @on_event.call(buffer.string)
+    @on_event.call(event, buffer.string)
   end
 end