org.apache.flink.streaming.connectors.kafka

Class Kafka08TableSourceSinkFactory

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase

org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactory

All Implemented Interfaces:

StreamTableSinkFactory<Row>, StreamTableSourceFactory<Row>, TableFactory, TableSinkFactory<Row>, TableSourceFactory<Row>

public class Kafka08TableSourceSinkFactory
extends KafkaTableSourceSinkFactoryBase

Factory for creating configured instances of Kafka08TableSource.

Constructor Summary

Constructors

Constructor and Description
Kafka08TableSourceSinkFactory()

Method Summary

Modifier and Type	Method and Description
protected KafkaTableSinkBase	createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema) Constructs the version-specific Kafka table sink.
protected KafkaTableSourceBase	createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Constructs the version-specific Kafka table source.
protected String	kafkaVersion() Returns the Kafka version.
protected boolean	supportsKafkaTimestamps() True if the Kafka source supports Kafka timestamps, false otherwise.

Methods inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase

createStreamTableSink, createStreamTableSource, requiredContext, supportedProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.factories.StreamTableSourceFactory

createTableSource

Methods inherited from interface org.apache.flink.table.factories.TableSourceFactory

createTableSource

Methods inherited from interface org.apache.flink.table.factories.StreamTableSinkFactory

createTableSink

Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

createTableSink

Constructor Detail

Kafka08TableSourceSinkFactory

public Kafka08TableSourceSinkFactory()

Method Detail

kafkaVersion

protected String kafkaVersion()

Description copied from class: KafkaTableSourceSinkFactoryBase

Returns the Kafka version.

Specified by:

kafkaVersion in class KafkaTableSourceSinkFactoryBase

supportsKafkaTimestamps

protected boolean supportsKafkaTimestamps()

Description copied from class: KafkaTableSourceSinkFactoryBase

True if the Kafka source supports Kafka timestamps, false otherwise.

Specified by:

supportsKafkaTimestamps in class KafkaTableSourceSinkFactoryBase

Returns:

True if the Kafka source supports Kafka timestamps, false otherwise.

createKafkaTableSource

protected KafkaTableSourceBase createKafkaTableSource(TableSchema schema,
                                                      Optional<String> proctimeAttribute,
                                                      List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors,
                                                      Map<String,String> fieldMapping,
                                                      String topic,
                                                      Properties properties,
                                                      DeserializationSchema<Row> deserializationSchema,
                                                      StartupMode startupMode,
                                                      Map<KafkaTopicPartition,Long> specificStartupOffsets)

Description copied from class: KafkaTableSourceSinkFactoryBase

Constructs the version-specific Kafka table source.

Specified by:

createKafkaTableSource in class KafkaTableSourceSinkFactoryBase

Parameters:

schema - Schema of the produced table.

proctimeAttribute - Field name of the processing time attribute.

rowtimeAttributeDescriptors - Descriptor for a rowtime attribute

fieldMapping - Mapping for the fields of the table schema to fields of the physical returned type.

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

deserializationSchema - Deserialization schema for decoding records from Kafka.

startupMode - Startup mode for the contained consumer.

specificStartupOffsets - Specific startup offsets; only relevant when startup mode is StartupMode.SPECIFIC_OFFSETS.

createKafkaTableSink

protected KafkaTableSinkBase createKafkaTableSink(TableSchema schema,
                                                  String topic,
                                                  Properties properties,
                                                  Optional<FlinkKafkaPartitioner<Row>> partitioner,
                                                  SerializationSchema<Row> serializationSchema)

Description copied from class: KafkaTableSourceSinkFactoryBase

Constructs the version-specific Kafka table sink.

Specified by:

createKafkaTableSink in class KafkaTableSourceSinkFactoryBase

Parameters:

schema - Schema of the produced table.

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

partitioner - Partitioner to select Kafka partition for each item.