Uses of Class
org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchemaBuilder

Packages that use KafkaRecordSerializationSchemaBuilder

Package	Description
org.apache.flink.connector.kafka.sink

Uses of KafkaRecordSerializationSchemaBuilder in org.apache.flink.connector.kafka.sink

Methods in org.apache.flink.connector.kafka.sink that return KafkaRecordSerializationSchemaBuilder

Modifier and Type	Method and Description
static <T> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchema.builder() Creates a default schema builder to provide common building blocks i.e.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKafkaKeySerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<? super T>> keySerializer) Sets Kafka's Serializer to serialize incoming elements to the key of the ProducerRecord.
<T extends IN,S extends org.apache.kafka.common.serialization.Serializer<? super T>> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKafkaKeySerializer(Class<S> keySerializer, Map<String,String> configuration) Sets a configurable Kafka Serializer and pass a configuration to serialize incoming elements to the key of the ProducerRecord.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKafkaValueSerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<? super T>> valueSerializer) Sets Kafka's Serializer to serialize incoming elements to the value of the ProducerRecord.
<T extends IN,S extends org.apache.kafka.common.serialization.Serializer<? super T>> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKafkaValueSerializer(Class<S> valueSerializer, Map<String,String> configuration) Sets a configurable Kafka Serializer and pass a configuration to serialize incoming elements to the value of the ProducerRecord.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKeySerializationSchema(SerializationSchema<? super T> keySerializationSchema) Sets a SerializationSchema which is used to serialize the incoming element to the key of the ProducerRecord.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setPartitioner(FlinkKafkaPartitioner<? super T> partitioner) Sets a custom partitioner determining the target partition of the target topic.
KafkaRecordSerializationSchemaBuilder<IN>	KafkaRecordSerializationSchemaBuilder.setTopic(String topic) Sets a fixed topic which used as destination for all records.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setTopicSelector(TopicSelector<? super T> topicSelector) Sets a topic selector which computes the target topic for every incoming record.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setValueSerializationSchema(SerializationSchema<T> valueSerializationSchema) Sets a SerializationSchema which is used to serialize the incoming element to the value of the ProducerRecord.