IncomingKafkaCloudEventMetadata (SmallRye Reactive Messaging 3.9.0 API)

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	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

All Methods Instance Methods Default Methods
Modifier and Type Method 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