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

Kafka storage plugin.

See: Description

Interface Summary

Interface	Description
TestQueryConstants

Class Summary

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

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.