Modifier and Type | Method and Description |
---|---|
KafkaSourceBuilder<OUT> |
KafkaSourceBuilder.setDeserializer(KafkaRecordDeserializationSchema<OUT> recordDeserializer)
Sets the
deserializer of the ConsumerRecord for KafkaSource. |
Constructor and Description |
---|
KafkaRecordEmitter(KafkaRecordDeserializationSchema<T> deserializationSchema) |
Modifier and Type | Method and Description |
---|---|
static <V> KafkaRecordDeserializationSchema<V> |
KafkaRecordDeserializationSchema.of(KafkaDeserializationSchema<V> kafkaDeserializationSchema)
Wraps a legacy
KafkaDeserializationSchema as the deserializer of the ConsumerRecords . |
static <V> KafkaRecordDeserializationSchema<V> |
KafkaRecordDeserializationSchema.valueOnly(Class<? extends org.apache.kafka.common.serialization.Deserializer<V>> valueDeserializerClass)
Wraps a Kafka
Deserializer to a KafkaRecordDeserializationSchema . |
static <V,D extends org.apache.kafka.common.serialization.Deserializer<V>> |
KafkaRecordDeserializationSchema.valueOnly(Class<D> valueDeserializerClass,
Map<String,String> config)
Wraps a Kafka
Deserializer to a KafkaRecordDeserializationSchema . |
static <V> KafkaRecordDeserializationSchema<V> |
KafkaRecordDeserializationSchema.valueOnly(DeserializationSchema<V> valueDeserializationSchema)
Wraps a
DeserializationSchema as the value deserialization schema of the ConsumerRecords . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.