Class DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
java.lang.Object
org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
- Enclosing class:
- DeadLetterPublishingRecoverer.HeaderNames.Builder
Headers for data relative to the original record.
- Since:
- 2.7
- Author:
- Tomaz Fernandes
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionconsumerGroupHeader
(String consumerGroupHeader) Sets the name of the header that will be used to store the consumer group that failed to consume the original record.Returns the exception builder.offsetHeader
(String offsetHeader) Sets the name of the header that will be used to store the offset of the original record.partitionHeader
(String partitionHeader) Sets the name of the header that will be used to store the partition of the original record.timestampHeader
(String timestampHeader) Sets the name of the header that will be used to store the timestamp of the original record.timestampTypeHeader
(String timestampTypeHeader) Sets the name of the header that will be used to store the timestampType of the original record.topicHeader
(String topicHeader) Sets the name of the header that will be used to store the topic of the original record.
-
Constructor Details
-
Original
public Original()
-
-
Method Details
-
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
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
Returns the exception builder.- Returns:
- the exception builder.
- Since:
- 2.7
-