@Internal public class Kafka010DynamicSource extends KafkaDynamicSourceBase
StreamTableSource
for Kafka 0.10.ScanTableSource.ScanContext, ScanTableSource.ScanRuntimeProvider
DynamicTableSource.Context, DynamicTableSource.DataStructureConverter
decodingFormat, outputDataType, properties, specificStartupOffsets, startupMode, startupTimestampMillis, topic
Constructor and Description |
---|
Kafka010DynamicSource(DataType outputDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Creates a Kafka 0.10
StreamTableSource . |
Modifier and Type | Method and Description |
---|---|
String |
asSummaryString()
Returns a string that summarizes this source for printing to a console or log.
|
DynamicTableSource |
copy()
Creates a copy of this instance during planning.
|
protected FlinkKafkaConsumerBase<RowData> |
createKafkaConsumer(String topic,
Properties properties,
DeserializationSchema<RowData> deserializationSchema)
Creates a version-specific Kafka consumer.
|
equals, getChangelogMode, getKafkaConsumer, getScanRuntimeProvider, hashCode
public Kafka010DynamicSource(DataType outputDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
StreamTableSource
.outputDataType
- Source output 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
startupTimestampMillis
- Startup timestamp for offsets; only relevant when startup mode
is StartupMode.TIMESTAMP
protected FlinkKafkaConsumerBase<RowData> createKafkaConsumer(String topic, Properties properties, DeserializationSchema<RowData> deserializationSchema)
KafkaDynamicSourceBase
createKafkaConsumer
in class KafkaDynamicSourceBase
topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.deserializationSchema
- Deserialization schema to use for Kafka records.public DynamicTableSource copy()
DynamicTableSource
public String asSummaryString()
DynamicTableSource
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.