Module io.cloudevents.kafka

Package io.cloudevents.kafka.impl

Class KafkaHeaders

java.lang.Object

io.cloudevents.kafka.impl.KafkaHeaders

public class KafkaHeaders
extends Object

Helper class that contains Kafka headers that should be attached either a binary or structured event message.

Author:

Francesco Guardiani, Florian Hussonnois

Field Summary

Fields

Modifier and Type	Field	Description
protected static final Map<String,String>	ATTRIBUTES_TO_HEADERS
protected static final String	CE_PREFIX
static final String	CONTENT_TYPE
static final String	SPEC_VERSION

Constructor Summary

Constructors

Constructor	Description
KafkaHeaders()

Method Summary

Modifier and Type	Method	Description
static String	getParsedKafkaHeader(Headers headers, String key)

Methods inherited from class java.lang.Object

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

Field Details

CE_PREFIX

protected static final String CE_PREFIX

See Also:

• Constant Field Values

CONTENT_TYPE

public static final String CONTENT_TYPE

See Also:

• Constant Field Values

ATTRIBUTES_TO_HEADERS

protected static final Map<String,String> ATTRIBUTES_TO_HEADERS

SPEC_VERSION

public static final String SPEC_VERSION

Constructor Details

KafkaHeaders

public KafkaHeaders()

Method Details

getParsedKafkaHeader

public static String getParsedKafkaHeader(Headers headers,
 String key)