class Karafka::Parsers::Avro::Parser
Attributes
avro[R]
schema_name[R]
Public Class Methods
new(avro, schema_name)
click to toggle source
# File lib/karafka/parsers/avro/parser.rb, line 12 def initialize(avro, schema_name) @avro = avro @schema_name = schema_name end
Public Instance Methods
generate(content)
click to toggle source
# File lib/karafka/parsers/avro/parser.rb, line 21 def generate(content) avro.encode(content, schema_name: schema_name) end
parse(content)
click to toggle source
# File lib/karafka/parsers/avro/parser.rb, line 17 def parse(content) avro.decode(content, schema_name: schema_name) end