Class | Description |
---|---|
Kafka010DynamicSink |
Kafka 0.10 table sink for writing data into Kafka.
|
Kafka010DynamicSource |
Kafka
StreamTableSource for Kafka 0.10. |
Kafka010DynamicTableFactory |
Factory for creating configured instances of
Kafka010DynamicSource . |
Kafka011DynamicSink |
Kafka 0.11 table sink for writing data into Kafka.
|
Kafka011DynamicSource |
Kafka
StreamTableSource for Kafka 0.11. |
Kafka011DynamicTableFactory |
Factory for creating configured instances of
Kafka011DynamicSource . |
KafkaDynamicSink |
Kafka table sink for writing data into Kafka.
|
KafkaDynamicSinkBase |
A version-agnostic Kafka
DynamicTableSink . |
KafkaDynamicSource |
Kafka
DynamicTableSource . |
KafkaDynamicSourceBase |
A version-agnostic Kafka
ScanTableSource . |
KafkaDynamicTableFactory |
Factory for creating configured instances of
KafkaDynamicSource . |
KafkaDynamicTableFactoryBase |
Factory for creating configured instances of
KafkaDynamicSourceBase and KafkaDynamicSinkBase . |
KafkaOptions |
Option utils for Kafka table source sink.
|
KafkaOptions.StartupOptions |
Kafka startup options.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.