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