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

Interface Summary

Interface	Description
MessageReader	MessageReader interface provides mechanism to handle various Kafka Message Formats like JSON, AVRO or custom message formats.

Class Summary

Class	Description
AvroMessageReader
JsonMessageReader	MessageReader class which will convert ConsumerRecord into JSON and writes to VectorContainerWriter of JsonReader
JsonMessageReader.SingleElementIterator<T>
KafkaJsonLoader
KafkaJsonLoader.KafkaJsonLoaderBuilder
MessageReaderFactory
MessageReaderFactoryTest