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