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

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

Related Packages

Package	Description
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kafka.schema

Class	Description
AvroMessageReader
JsonMessageReader	MessageReader class which will convert ConsumerRecord into JSON and writes to VectorContainerWriter of JsonReader
KafkaJsonLoader
KafkaJsonLoader.KafkaJsonLoaderBuilder
MessageReader	MessageReader interface provides mechanism to handle various Kafka Message Formats like JSON, AVRO or custom message formats.
MessageReaderFactory