Modifier and Type | Method and Description |
---|---|
KafkaSourceBuilder<OUT> |
KafkaSourceBuilder.setDeserializer(KafkaRecordDeserializer<OUT> recordDeserializer)
Sets the
deserializer of the ConsumerRecord for KafkaSource. |
Constructor and Description |
---|
KafkaPartitionSplitReader(Properties props,
KafkaRecordDeserializer<T> deserializationSchema,
int subtaskId) |
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.valueOnly(Class<D> valueDeserializerClass,
Map<String,String> config)
Wraps a Kafka
Deserializer to a KafkaRecordDeserializer . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.