org.apache.flink.statefun.sdk.kafka

Interface KafkaIngressDeserializer<T>

Type Parameters:

T - The type created by the keyed deserialization schema.

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

RoutableKafkaIngressDeserializer

public interface KafkaIngressDeserializer<T>
extends java.io.Serializable

The deserialization schema describes how to turn the Kafka ConsumerRecords into data types that are processed by the system.

Method Summary

Modifier and Type	Method and Description
T	deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> input) Deserializes the Kafka record.

Method Detail

deserialize

T deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> input)

Deserializes the Kafka record.

Parameters:

input - Kafka record to be deserialized.

Returns:

The deserialized message as an object (null if the message cannot be deserialized).