Package com.bakdata.kafka.streams.kstream

Class LineageHeaders

java.lang.Object

com.bakdata.kafka.streams.kstream.LineageHeaders

public class LineageHeaders
extends Object

Configure headers for data lineage of Kafka messages

Field Summary

Fields

Modifier and Type	Field	Description
static final String	OFFSET_HEADER	Header indicating the offset the record was read from.
static final String	PARTITION_HEADER	Header indicating the partition the record was read from.
static final String	TOPIC_HEADER	Header indicating the topic the record was read from.

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

TOPIC_HEADER

public static final String TOPIC_HEADER

Header indicating the topic the record was read from.

See Also:

• Constant Field Values

PARTITION_HEADER

public static final String PARTITION_HEADER

Header indicating the partition the record was read from.

See Also:

• Constant Field Values

OFFSET_HEADER

public static final String OFFSET_HEADER

Header indicating the offset the record was read from.

See Also:

• Constant Field Values