Package for kafka listeners
-
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.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()
Sets the name of the header that will be used to store the partition
of the original record.
Sets the name of the header that will be used to store the timestamp
of the original record.
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.