public final class RoutableProtobufKafkaIngressDeserializer extends java.lang.Object implements KafkaIngressDeserializer<com.google.protobuf.Message>
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Message |
deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> input)
Deserializes the Kafka record.
|
public com.google.protobuf.Message deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> input)
KafkaIngressDeserializer
deserialize
in interface KafkaIngressDeserializer<com.google.protobuf.Message>
input
- Kafka record to be deserialized.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.