org.apache.flink.streaming.connectors.kafka.table
Classes
KafkaDynamicSink
KafkaDynamicSource
KafkaDynamicTableFactory
KafkaOptions
KafkaOptions.StartupOptions
UpsertKafkaDynamicTableFactory
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper
Enums
KafkaOptions.ValueFieldsStrategy
KafkaSinkSemantic