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 java.lang.Object
Headers for data relative to the original record.- Since:
- 2.7
- Author:
- Tomaz Fernandes
-
-
Constructor Summary
Constructors Constructor Description Original()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
consumerGroupHeader(java.lang.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(java.lang.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(java.lang.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(java.lang.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(java.lang.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(java.lang.String topicHeader)
Sets the name of the header that will be used to store the topic of the original record.
-
-
-
Method Detail
-
offsetHeader
public DeadLetterPublishingRecoverer.HeaderNames.Builder.Original offsetHeader(java.lang.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(java.lang.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(java.lang.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(java.lang.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(java.lang.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(java.lang.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
-
-