Package org.springframework.kafka.listener

Class DeadLetterPublishingRecoverer.HeaderNames.Original

java.lang.Object

org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original

Enclosing class:

DeadLetterPublishingRecoverer.HeaderNames

public static class DeadLetterPublishingRecoverer.HeaderNames.Original
extends Object

Header names for original record property headers.

Since:

2.8.4

Method Summary

Modifier and Type	Method	Description
String	getConsumerGroup()	The header name for the consumer group.
String	getOffsetHeader()	The header name for the offset.
String	getPartitionHeader()	The header name for the partition.
String	getTimestampHeader()	The header name for the timestamp.
String	getTimestampTypeHeader()	The header name for the timestamp type.
String	getTopicHeader()	The header name for the topic.

Methods inherited from class java.lang.Object

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

Method Details

getOffsetHeader

public String getOffsetHeader()

The header name for the offset.

Returns:

the offsetHeader.

getTimestampHeader

public String getTimestampHeader()

The header name for the timestamp.

Returns:

the timestampHeader.

getTimestampTypeHeader

public String getTimestampTypeHeader()

The header name for the timestamp type.

Returns:

the timestampTypeHeader.

getTopicHeader

public String getTopicHeader()

The header name for the topic.

Returns:

the topicHeader.

getPartitionHeader

public String getPartitionHeader()

The header name for the partition.

Returns:

the partitionHeader

getConsumerGroup

public String getConsumerGroup()

The header name for the consumer group.

Returns:

the consumerGroup