class Avro2Kafka::AvroReader

Attributes

io[R]

Public Class Methods

new(io) click to toggle source
# File lib/avro2kafka/avro_reader.rb, line 7
def initialize(io)
  @io = io
  @reader = Avro::IO::DatumReader.new()
end

Public Instance Methods

read() click to toggle source
# File lib/avro2kafka/avro_reader.rb, line 12
def read
  Avro::DataFile::Reader.new(io, @reader).to_enum
end