public class KafkaDynamicTableFactory extends KafkaDynamicTableFactoryBase
KafkaDynamicSource
.DynamicTableFactory.Context
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
Constructor and Description |
---|
KafkaDynamicTableFactory() |
Modifier and Type | Method and Description |
---|---|
protected KafkaDynamicSinkBase |
createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat)
Constructs the version-specific Kafka table sink.
|
protected KafkaDynamicSourceBase |
createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Constructs the version-specific Kafka table source.
|
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
createDynamicTableSink, createDynamicTableSource, optionalOptions, requiredOptions
public static final String IDENTIFIER
protected KafkaDynamicSourceBase createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
KafkaDynamicTableFactoryBase
createKafkaTableSource
in class KafkaDynamicTableFactoryBase
producedDataType
- Source produced data typetopic
- Kafka topic to consumeproperties
- Properties for the Kafka consumerdecodingFormat
- Decoding format for decoding records from KafkastartupMode
- Startup mode for the contained consumerspecificStartupOffsets
- Specific startup offsets; only relevant when startup mode is
StartupMode.SPECIFIC_OFFSETS
protected KafkaDynamicSinkBase createKafkaTableSink(DataType consumedDataType, String topic, Properties properties, Optional<FlinkKafkaPartitioner<RowData>> partitioner, EncodingFormat<SerializationSchema<RowData>> encodingFormat)
KafkaDynamicTableFactoryBase
createKafkaTableSink
in class KafkaDynamicTableFactoryBase
consumedDataType
- Sink consumed data typetopic
- Kafka topic to consumeproperties
- Properties for the Kafka consumerpartitioner
- Partitioner to select Kafka partition for each itemencodingFormat
- Encoding format for encoding records to Kafkapublic String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. kafka-0.10
).
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.