Package org.springframework.kafka.listener

Class DeadLetterPublishingRecoverer.SingleRecordHeader

java.lang.Object
org.apache.kafka.common.header.internals.RecordHeader
org.springframework.kafka.listener.DeadLetterPublishingRecoverer.SingleRecordHeader
All Implemented Interfaces:
org.apache.kafka.common.header.Header
Enclosing class:
DeadLetterPublishingRecoverer
public static class DeadLetterPublishingRecoverer.SingleRecordHeader extends org.apache.kafka.common.header.internals.RecordHeader
A Header that indicates that this header should replace any existing headers with this name, rather than being appended to the headers, which is the normal behavior.
Since:
2.9.5
See Also:

  • Constructor Details

    • SingleRecordHeader

      public SingleRecordHeader(String key, byte[] value)
      Construct an instance.
      Parameters:
      key - the key.
      value - the value.

    • SingleRecordHeader

      public SingleRecordHeader(ByteBuffer keyBuffer, ByteBuffer valueBuffer)
      Construct an instance.
      Parameters:
      keyBuffer - the key buffer.
      valueBuffer - the value buffer.