Module io.cloudevents.kafka

Package io.cloudevents.kafka

Class CloudEventMessageDeserializer

java.lang.Object

io.cloudevents.kafka.CloudEventMessageDeserializer

All Implemented Interfaces:

Closeable, AutoCloseable, Deserializer<io.cloudevents.core.message.MessageReader>

public class CloudEventMessageDeserializer
extends Object
implements Deserializer<io.cloudevents.core.message.MessageReader>

Kafka Deserializer for MessageReader.

Constructor Summary

Constructors

Constructor	Description
CloudEventMessageDeserializer()

Method Summary

Modifier and Type	Method	Description
io.cloudevents.core.message.MessageReader	deserialize(String topic, byte[] data)
io.cloudevents.core.message.MessageReader	deserialize(String topic, Headers headers, byte[] data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

close, configure, deserialize

Constructor Details

CloudEventMessageDeserializer

public CloudEventMessageDeserializer()

Method Details

deserialize

public io.cloudevents.core.message.MessageReader deserialize(String topic,
 byte[] data)

Specified by:

deserialize in interface Deserializer<io.cloudevents.core.message.MessageReader>

deserialize

public io.cloudevents.core.message.MessageReader deserialize(String topic,
 Headers headers,
 byte[] data)

Specified by:

deserialize in interface Deserializer<io.cloudevents.core.message.MessageReader>