Package org.apache.calcite.adapter.kafka

package org.apache.calcite.adapter.kafka

Kafka query provider.

One Kafka topic is mapping to one STREAM table.

Class	Description
KafkaMessageEnumerator<K,V>	Enumerator to read data from Consumer, and converted into SQL rows with KafkaRowConverter.
KafkaRowConverter<K,V>	Interface to handle formatting between Kafka message and Calcite row.
KafkaRowConverterImpl	Default implementation of KafkaRowConverter, both key and value are byte[].
KafkaStreamTable	A table that maps to an Apache Kafka topic.
KafkaTableFactory	Implementation of TableFactory for Apache Kafka.
KafkaTableOptions	Available options for KafkaStreamTable.