protected KafkaDynamicSinkBase |
KafkaDynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected KafkaDynamicSinkBase |
Kafka011DynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected KafkaDynamicSinkBase |
Kafka010DynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected abstract KafkaDynamicSinkBase |
KafkaDynamicTableFactoryBase.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat)
Constructs the version-specific Kafka table sink.
|