Interface | Description |
---|---|
KafkaRecordSerializationSchema<T> |
A serialization schema which defines how to convert a value of type
T to ProducerRecord . |
KafkaRecordSerializationSchema.KafkaSinkContext |
Context providing information of the kafka record target location.
|
TopicSelector<IN> |
Selects a topic for the incoming record.
|
Class | Description |
---|---|
DefaultKafkaSinkContext |
Context providing information to assist constructing a
ProducerRecord . |
KafkaRecordSerializationSchemaBuilder<IN> |
Builder to construct
KafkaRecordSerializationSchema . |
KafkaSink<IN> |
Flink Sink to produce data into a Kafka topic.
|
KafkaSinkBuilder<IN> |
Builder to construct
KafkaSink . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.