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

Kafka storage plugin.

See: Description

Class Summary

Class	Description
KafkaAsyncCloser	Closes Kafka resources asynchronously which result does not depend on close method in order to improve query execution performance.
KafkaGroupScan
KafkaGroupScan.PartitionScanWork
KafkaPartitionScanSpec
KafkaPartitionScanSpecBuilder
KafkaPushDownFilterIntoScan
KafkaRecordReader
KafkaScanBatchCreator
KafkaScanSpec
KafkaStoragePlugin
KafkaStoragePluginConfig
KafkaSubScan
MessageIterator
ReadOptions	Holds all system / session options that are used during data read from Kafka.

Enum Summary

Enum	Description
MetaDataField	MetaData fields provide additional information about each message.

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

Kafka storage plugin. Enables querying Kafka as a data store, supported for Avro and Json message types.