org.apache.flink.streaming.connectors.kafka

Class Kafka09TableSink

java.lang.Object

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

org.apache.flink.streaming.connectors.kafka.Kafka09TableSink

All Implemented Interfaces:

org.apache.flink.table.sinks.AppendStreamTableSink<Row>, org.apache.flink.table.sinks.StreamTableSink<Row>, org.apache.flink.table.sinks.TableSink<Row>

@Internal
public class Kafka09TableSink
extends KafkaTableSink

Kafka 0.9 table sink for writing data into Kafka.

Field Summary

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

fieldNames, fieldTypes, partitioner, properties, serializationSchema, topic

Constructor Summary

Constructors

Constructor and Description
Kafka09TableSink(org.apache.flink.table.api.TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)

Method Summary

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

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

configure, createCopy, createSerializationSchema, emitDataStream, equals, getFieldNames, getFieldTypes, getOutputType, hashCode

Methods inherited from class java.lang.Object

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

Constructor Detail

Kafka09TableSink

public Kafka09TableSink(org.apache.flink.table.api.TableSchema schema,
                        String topic,
                        Properties properties,
                        Optional<FlinkKafkaPartitioner<Row>> partitioner,
                        SerializationSchema<Row> serializationSchema)

Method Detail

createKafkaProducer

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

Description copied from class: KafkaTableSink

Returns the version-specific Kafka producer.

Specified by:

createKafkaProducer in class KafkaTableSink

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