Uses of Interface
org.apache.flink.connector.kafka.source.reader.deserializer.KafkaRecordDeserializer

Packages that use KafkaRecordDeserializer

Package	Description
org.apache.flink.connector.kafka.source
org.apache.flink.connector.kafka.source.reader
org.apache.flink.connector.kafka.source.reader.deserializer

Uses of KafkaRecordDeserializer in org.apache.flink.connector.kafka.source

Methods in org.apache.flink.connector.kafka.source with parameters of type KafkaRecordDeserializer

Modifier and Type	Method and Description
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setDeserializer(KafkaRecordDeserializer<OUT> recordDeserializer) Sets the deserializer of the ConsumerRecord for KafkaSource.

Uses of KafkaRecordDeserializer in org.apache.flink.connector.kafka.source.reader

Constructors in org.apache.flink.connector.kafka.source.reader with parameters of type KafkaRecordDeserializer

Constructor and Description
KafkaPartitionSplitReader(Properties props, KafkaRecordDeserializer<T> deserializationSchema, int subtaskId)

Uses of KafkaRecordDeserializer in org.apache.flink.connector.kafka.source.reader.deserializer

Methods in org.apache.flink.connector.kafka.source.reader.deserializer that return KafkaRecordDeserializer

Modifier and Type	Method and Description
static <V> KafkaRecordDeserializer<V>	KafkaRecordDeserializer.valueOnly(Class<? extends org.apache.kafka.common.serialization.Deserializer<V>> valueDeserializerClass) Wraps a Kafka Deserializer to a KafkaRecordDeserializer.
static <V,D extends org.apache.kafka.common.Configurable & org.apache.kafka.common.serialization.Deserializer<V>> KafkaRecordDeserializer<V>	KafkaRecordDeserializer.valueOnly(Class<D> valueDeserializerClass, Map<String,String> config) Wraps a Kafka Deserializer to a KafkaRecordDeserializer.