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.ObjectHeaders 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.OriginalconsumerGroupHeader(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.ExceptionInfoexception()Returns the exception builder.DeadLetterPublishingRecoverer.HeaderNames.Builder.OriginaloffsetHeader(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.OriginalpartitionHeader(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.OriginaltimestampHeader(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.OriginaltimestampTypeHeader(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.OriginaltopicHeader(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
-
-