@Internal public class Kafka011DynamicSink extends KafkaDynamicSinkBase
DynamicTableSink.Context, DynamicTableSink.DataStructureConverter, DynamicTableSink.SinkRuntimeProvider
consumedDataType, encodingFormat, partitioner, properties, topic
Constructor and Description |
---|
Kafka011DynamicSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
Modifier and Type | Method and Description |
---|---|
String |
asSummaryString()
Returns a string that summarizes this sink for printing to a console or log.
|
DynamicTableSink |
copy()
Creates a copy of this instance during planning.
|
protected SinkFunction<RowData> |
createKafkaProducer(String topic,
Properties properties,
SerializationSchema<RowData> serializationSchema,
Optional<FlinkKafkaPartitioner<RowData>> partitioner)
Returns the version-specific Kafka producer.
|
equals, getChangelogMode, getSinkRuntimeProvider, hashCode
public Kafka011DynamicSink(DataType consumedDataType, String topic, Properties properties, Optional<FlinkKafkaPartitioner<RowData>> partitioner, EncodingFormat<SerializationSchema<RowData>> encodingFormat)
protected SinkFunction<RowData> createKafkaProducer(String topic, Properties properties, SerializationSchema<RowData> serializationSchema, Optional<FlinkKafkaPartitioner<RowData>> partitioner)
KafkaDynamicSinkBase
createKafkaProducer
in class KafkaDynamicSinkBase
topic
- Kafka topic to produce to.properties
- Properties for the Kafka producer.serializationSchema
- Serialization schema to use to create Kafka records.partitioner
- Partitioner to select Kafka partition.public DynamicTableSink copy()
DynamicTableSink
public String asSummaryString()
DynamicTableSink
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.