Package org.springframework.kafka.listener

Class DeadLetterPublishingRecoverer.HeaderNames.Builder.Original

java.lang.Object

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

Enclosing class:

DeadLetterPublishingRecoverer.HeaderNames.Builder

public class DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
extends Object

Headers for data relative to the original record.

Since:

2.7

Author:

Tomaz Fernandes

Constructor Summary

Constructors

Constructor	Description
Original()

Method Summary

Modifier and Type	Method	Description
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	consumerGroupHeader(String consumerGroupHeader)	Sets the name of the header that will be used to store the consumer group that failed to consume the original record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo	exception()	Returns the exception builder.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	offsetHeader(String offsetHeader)	Sets the name of the header that will be used to store the offset of the original record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	partitionHeader(String partitionHeader)	Sets the name of the header that will be used to store the partition of the original record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	timestampHeader(String timestampHeader)	Sets the name of the header that will be used to store the timestamp of the original record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	timestampTypeHeader(String timestampTypeHeader)	Sets the name of the header that will be used to store the timestampType of the original record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	topicHeader(String topicHeader)	Sets the name of the header that will be used to store the topic of the original record.

Methods inherited from class java.lang.Object

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

Constructor Details

Original

public Original()

Method Details

offsetHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original offsetHeader(String offsetHeader)

Sets the name of the header that will be used to store the offset of the original record.

Parameters:

offsetHeader - the offset header name.

Returns:

the Original builder instance

Since:

2.7

timestampHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original timestampHeader(String timestampHeader)

Sets the name of the header that will be used to store the timestamp of the original record.

Parameters:

timestampHeader - the timestamp header name.

Returns:

the Original builder instance

Since:

2.7

timestampTypeHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original timestampTypeHeader(String timestampTypeHeader)

Sets the name of the header that will be used to store the timestampType of the original record.

Parameters:

timestampTypeHeader - the timestampType header name.

Returns:

the Original builder instance

Since:

2.7

topicHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original topicHeader(String topicHeader)

Sets the name of the header that will be used to store the topic of the original record.

Parameters:

topicHeader - the topic header name.

Returns:

the Original builder instance

Since:

2.7

partitionHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original partitionHeader(String partitionHeader)

Sets the name of the header that will be used to store the partition of the original record.

Parameters:

partitionHeader - the partition header name.

Returns:

the Original builder instance

Since:

2.7

consumerGroupHeader

public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original consumerGroupHeader(String consumerGroupHeader)

Sets the name of the header that will be used to store the consumer group that failed to consume the original record.

Parameters:

consumerGroupHeader - the consumer group header name.

Returns:

the Original builder instance

Since:

2.8

exception

public DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo exception()

Returns the exception builder.

Returns:

the exception builder.

Since:

2.7