org.apache.flink.streaming.connectors.kafka

Class KafkaTableSink

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase

org.apache.flink.streaming.connectors.kafka.KafkaTableSink

All Implemented Interfaces:

AppendStreamTableSink<Row>, StreamTableSink<Row>, TableSink<Row>

Deprecated.

Use KafkaDynamicSink via KafkaDynamicTableFactory.

@Deprecated
 @Internal
public class KafkaTableSink
extends KafkaTableSinkBase

Kafka table sink for writing data into Kafka.

Field Summary

Fields inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase

partitioner, properties, serializationSchema, topic

Constructor Summary

Constructors

Constructor and Description
KafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected SinkFunction<Row>	createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner) Deprecated. Returns the version-specific Kafka producer.

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

configure, consumeDataStream, equals, getFieldNames, getFieldTypes, getOutputType, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getConsumedDataType, getTableSchema

Constructor Detail

KafkaTableSink

public KafkaTableSink(TableSchema schema,
                      String topic,
                      Properties properties,
                      Optional<FlinkKafkaPartitioner<Row>> partitioner,
                      SerializationSchema<Row> serializationSchema)

Deprecated.

Method Detail

createKafkaProducer

protected SinkFunction<Row> createKafkaProducer(String topic,
                                                Properties properties,
                                                SerializationSchema<Row> serializationSchema,
                                                Optional<FlinkKafkaPartitioner<Row>> partitioner)

Deprecated.

Description copied from class: KafkaTableSinkBase

Returns the version-specific Kafka producer.

Specified by:

createKafkaProducer in class KafkaTableSinkBase

Parameters:

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.

Returns:

The version-specific Kafka producer