io.smallrye.reactive.messaging.kafka

Interface IncomingKafkaCloudEventMetadata<K,T>

Type Parameters:

T - the data type

All Superinterfaces:

CloudEventMetadata<T>, IncomingCloudEventMetadata<T>

All Known Implementing Classes:

DefaultIncomingKafkaCloudEventMetadata

public interface IncomingKafkaCloudEventMetadata<K,T>
extends IncomingCloudEventMetadata<T>

Addition "extension" attribute specific to incoming Kafka record

Field Summary

Fields

Modifier and Type	Field and Description
static String	CE_KAFKA_KEY Extension - attribute name associated with the record's key.
static String	CE_KAFKA_TOPIC Extension - attribute name associated with the record's topic.

Fields inherited from interface io.smallrye.reactive.messaging.ce.CloudEventMetadata

CE_ATTRIBUTE_DATA_CONTENT_TYPE, CE_ATTRIBUTE_DATA_SCHEMA, CE_ATTRIBUTE_ID, CE_ATTRIBUTE_SOURCE, CE_ATTRIBUTE_SPEC_VERSION, CE_ATTRIBUTE_SUBJECT, CE_ATTRIBUTE_TIME, CE_ATTRIBUTE_TYPE, CE_VERSION_1_0

Method Summary

Modifier and Type	Method and Description
default K	getKey()
default String	getTopic()

Methods inherited from interface io.smallrye.reactive.messaging.ce.CloudEventMetadata

getData, getDataContentType, getDataSchema, getExtension, getExtensions, getId, getSource, getSpecVersion, getSubject, getTimeStamp, getType

Field Detail

CE_KAFKA_KEY

static final String CE_KAFKA_KEY

Extension - attribute name associated with the record's key. Defined in the Kafka Protocol Binding for Cloud Events

See Also:

Constant Field Values

CE_KAFKA_TOPIC

static final String CE_KAFKA_TOPIC

Extension - attribute name associated with the record's topic.

See Also:

Constant Field Values

Method Detail

getKey

default K getKey()

Returns:

the record's key, @{code null} if none

getTopic

default String getTopic()

Returns:

the topic