Uses of Interface
org.apache.drill.exec.store.kafka.decoders.MessageReader

Packages that use MessageReader

Package	Description
org.apache.drill.exec.store.kafka.decoders

Uses of MessageReader in org.apache.drill.exec.store.kafka.decoders

Classes in org.apache.drill.exec.store.kafka.decoders that implement MessageReader

Modifier and Type	Class and Description
class	AvroMessageReader
class	JsonMessageReader MessageReader class which will convert ConsumerRecord into JSON and writes to VectorContainerWriter of JsonReader

Methods in org.apache.drill.exec.store.kafka.decoders that return MessageReader

Modifier and Type	Method and Description
static MessageReader	MessageReaderFactory.getMessageReader(String messageReaderKlass) Initialize kafka message reader based on store.kafka.record.reader session property