パッケージ org.springframework.kafka.listener

クラス DeadLetterPublishingRecoverer.SingleRecordHeader

java.lang.ObjectSE
org.apache.kafka.common.header.internals.RecordHeader
org.springframework.kafka.listener.DeadLetterPublishingRecoverer.SingleRecordHeader
実装されたすべてのインターフェース:
org.apache.kafka.common.header.Header
含まれているクラス:
DeadLetterPublishingRecoverer
public static class DeadLetterPublishingRecoverer.SingleRecordHeader extends org.apache.kafka.common.header.internals.RecordHeader
通常の動作であるヘッダーに追加されるのではなく、このヘッダーが既存のヘッダーをこの名前に置き換える必要があることを示す Header。
導入:
2.9.5
関連事項:

  • コンストラクターの詳細

    • SingleRecordHeader

      public SingleRecordHeader(StringSE key, byte[] value)
      インスタンスを構築します。
      パラメーター:
      key - キー。
      value - 値。

    • SingleRecordHeader

      public SingleRecordHeader(ByteBufferSE keyBuffer, ByteBufferSE valueBuffer)
      インスタンスを構築します。
      パラメーター:
      keyBuffer - キーバッファ。
      valueBuffer - バリューバッファ。