Package org.apache.drill.exec.store.kafka
package org.apache.drill.exec.store.kafka
Kafka storage plugin.
Enables querying Kafka as a data store, supported for Avro and Json message
types.
-
ClassDescriptionCloses Kafka resources asynchronously which result does not depend on close method in order to improve query execution performance.MetaData fields provide additional information about each message.Holds all system / session options that are used during data read from Kafka.