@Internal public class KafkaTableSink extends KafkaTableSinkBase
partitioner, properties, serializationSchema, topic
Constructor and Description |
---|
KafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
Modifier and Type | Method and Description |
---|---|
protected SinkFunction<Row> |
createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Returns the version-specific Kafka producer.
|
configure, consumeDataStream, equals, getFieldNames, getFieldTypes, getOutputType, hashCode
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getConsumedDataType, getTableSchema
public KafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected SinkFunction<Row> createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
KafkaTableSinkBase
createKafkaProducer
in class KafkaTableSinkBase
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.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.