Package org.springframework.kafka.listener

Class 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 Detail

      • Original

        public Original()

    • 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