Class | Description |
---|---|
KafkaConnectorOptions |
Options for the Kafka connector.
|
KafkaDynamicSink |
A version-agnostic Kafka
DynamicTableSink . |
KafkaDynamicSource |
A version-agnostic Kafka
ScanTableSource . |
KafkaDynamicTableFactory |
Factory for creating configured instances of
KafkaDynamicSource and KafkaDynamicSink . |
SinkBufferFlushMode |
Sink buffer flush configuration.
|
UpsertKafkaDynamicTableFactory |
Upsert-Kafka factory.
|
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper |
It is used to wrap the decoding format and expose the desired changelog mode.
|
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper |
It is used to wrap the encoding format and expose the desired changelog mode.
|
Enum | Description |
---|---|
KafkaConnectorOptions.ScanStartupMode |
Startup mode for the Kafka consumer, see
KafkaConnectorOptions.SCAN_STARTUP_MODE . |
KafkaConnectorOptions.ValueFieldsStrategy |
Strategies to derive the data type of a value format by considering a key format.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.