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