T
- The type created by the keyed deserialization schema.@PublicEvolving public interface KafkaDeserializationSchema<T> extends Serializable, ResultTypeQueryable<T>
Modifier and Type | Method and Description |
---|---|
T |
deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
Deserializes the Kafka record.
|
boolean |
isEndOfStream(T nextElement)
Method to decide whether the element signals the end of the stream.
|
getProducedType
boolean isEndOfStream(T nextElement)
nextElement
- The element to test for the end-of-stream signal.T deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) throws Exception
record
- Kafka record to be deserialized.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.