Module io.cloudevents.kafka

Package io.cloudevents.kafka.impl

Class KafkaBinaryMessageReaderImpl

java.lang.Object

io.cloudevents.core.message.impl.BaseBinaryMessageReader

io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

io.cloudevents.kafka.impl.KafkaBinaryMessageReaderImpl

All Implemented Interfaces:

io.cloudevents.core.message.MessageReader, io.cloudevents.core.message.StructuredMessageReader, io.cloudevents.rw.CloudEventReader

public class KafkaBinaryMessageReaderImpl
extends io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

Constructor Summary

Constructors

Constructor	Description
KafkaBinaryMessageReaderImpl(io.cloudevents.SpecVersion version, Headers headers, byte[] payload)

Method Summary

Modifier and Type	Method	Description
protected void	forEachHeader(BiConsumer<String,byte[]> fn)
protected boolean	isCloudEventsHeader(String key)
protected boolean	isContentTypeHeader(String key)
protected String	toCloudEventsKey(String key)
protected String	toCloudEventsValue(byte[] value)

Methods inherited from class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl

read

Methods inherited from class io.cloudevents.core.message.impl.BaseBinaryMessageReader

getEncoding, read

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.cloudevents.core.message.MessageReader

read, read, toEvent, toEvent

Constructor Details

KafkaBinaryMessageReaderImpl

public KafkaBinaryMessageReaderImpl(io.cloudevents.SpecVersion version,
 Headers headers,
 byte[] payload)

Method Details

isContentTypeHeader

protected boolean isContentTypeHeader(String key)

Specified by:

isContentTypeHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

isCloudEventsHeader

protected boolean isCloudEventsHeader(String key)

Specified by:

isCloudEventsHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

toCloudEventsKey

protected String toCloudEventsKey(String key)

Specified by:

toCloudEventsKey in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

forEachHeader

protected void forEachHeader(BiConsumer<String,byte[]> fn)

Specified by:

forEachHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>

toCloudEventsValue

protected String toCloudEventsValue(byte[] value)

Specified by:

toCloudEventsValue in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,byte[]>