class Fluent::Plugin::AvroTurfFormatter
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/formatter_confluent_avro.rb, line 16 def configure(conf) super @avro_turf = AvroTurf::Messaging.new(registry_url: @schema_registry_url) end
format(tag, time, record)
click to toggle source
# File lib/fluent/plugin/formatter_confluent_avro.rb, line 21 def format(tag, time, record) @avro_turf.encode(record, subject: @subject, version: @version) end