Module io.cloudevents.kafka

Package io.cloudevents.kafka

Class CloudEventMessageSerializer

java.lang.Object

io.cloudevents.kafka.CloudEventMessageSerializer

All Implemented Interfaces:

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

public class CloudEventMessageSerializer
extends Object
implements Serializer<io.cloudevents.core.message.MessageReader>

Kafka Serializer for MessageReader.

This Serializer can't be used as a key serializer.

Constructor Summary

Constructors

Constructor	Description
CloudEventMessageSerializer()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs, boolean isKey)
byte[]	serialize(String topic, io.cloudevents.core.message.MessageReader data)
byte[]	serialize(String topic, Headers headers, io.cloudevents.core.message.MessageReader 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.Serializer

close

Constructor Details

CloudEventMessageSerializer

public CloudEventMessageSerializer()

Method Details

configure

public void configure(Map<String,?> configs,
 boolean isKey)

Specified by:

configure in interface Serializer<io.cloudevents.core.message.MessageReader>

serialize

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

Specified by:

serialize in interface Serializer<io.cloudevents.core.message.MessageReader>

serialize

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

Specified by:

serialize in interface Serializer<io.cloudevents.core.message.MessageReader>