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	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	Description
static MessageReader	MessageReaderFactory.getMessageReader(String messageReaderKlass)	Initialize kafka message reader based on store.kafka.record.reader session property