org.apache.flink.streaming.connectors.kafka

Class Kafka08TableSink

java.lang.Object

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

org.apache.flink.streaming.connectors.kafka.Kafka08TableSink

All Implemented Interfaces:

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

@Internal
public class Kafka08TableSink
extends KafkaTableSinkBase

Kafka 0.8 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
Kafka08TableSink(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.KafkaTableSinkBase

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Kafka08TableSink

public Kafka08TableSink(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: 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