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

クラス HeaderEnricherProcessor<K,V>

java.lang.ObjectSE
org.apache.kafka.streams.processor.api.ContextualProcessor<K,V,K,V>
org.springframework.kafka.streams.HeaderEnricherProcessor<K,V>
型パラメーター:
K - 入力キーの型。
V - 入力値の型。
実装されたすべてのインターフェース:
org.apache.kafka.streams.processor.api.Processor<K,V,K,V>
public class HeaderEnricherProcessor<K,V> extends org.apache.kafka.streams.processor.api.ContextualProcessor<K,V,K,V>
ヘッダーを操作します。
導入:
3.0
作成者:
Gary Russell

  • ネストされたクラスのサマリー

    ネストされたクラス
    修飾子と型
    クラス
    説明
    static final class
    HeaderEnricherProcessor.Container<K,V>
    SpEL 評価用のコンテナーオブジェクト。

  • コンストラクターの概要

    コンストラクター
    コンストラクター
    説明
    HeaderEnricherProcessor(MapSE<StringSE,Expression> headerExpressions)
    提供されたヘッダー式でインスタンスを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    close()
    void
    process(org.apache.kafka.streams.processor.api.Record<K,V> record)

    クラス org.apache.kafka.streams.processor.api.ContextualProcessor から継承されたメソッド

    context, init

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

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

    • HeaderEnricherProcessor

      public HeaderEnricherProcessor(MapSE<StringSE,Expression> headerExpressions)
      提供されたヘッダー式でインスタンスを構築します。
      パラメーター:
      headerExpressions - ヘッダー式 ; 名前: 式。

  • メソッドの詳細

    • process

      public void process(org.apache.kafka.streams.processor.api.Record<K,V> record)

    • close

      public void close()