org.apache.flink.streaming.connectors.kafka.table
Classes
KafkaConnectorOptions
KafkaDynamicSink
KafkaDynamicSource
KafkaDynamicTableFactory
SinkBufferFlushMode
UpsertKafkaDynamicTableFactory
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper
Enums
KafkaConnectorOptions.ScanStartupMode
KafkaConnectorOptions.ValueFieldsStrategy