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

クラス MessagingProcessor<Kin,Vin,Kout,Vout>

java.lang.ObjectSE
org.apache.kafka.streams.processor.api.ContextualProcessor<Kin,Vin,Kout,Vout>
org.springframework.kafka.streams.messaging.MessagingProcessor<Kin,Vin,Kout,Vout>
型パラメーター:
Kin - 入力キーの型。
Vin - 入力値の型。
Kout - 出力キーの型。
Vout - 出力値の型。
実装されたすべてのインターフェース:
org.apache.kafka.streams.processor.api.Processor<Kin,Vin,Kout,Vout>
public class MessagingProcessor<Kin,Vin,Kout,Vout> extends org.apache.kafka.streams.processor.api.ContextualProcessor<Kin,Vin,Kout,Vout>
spring-messaging Message との間で変換する MessagingFunction を呼び出す Transformer 実装。たとえば、Spring Integration フローを呼び出すために使用できます。
導入:
2.3
作成者:
Gary Russell

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

    • MessagingProcessor

      public MessagingProcessor(MessagingFunction function, MessagingMessageConverter converter)
      提供された関数とコンバーターを使用してインスタンスを構築します。
      パラメーター:
      function - 関数。
      converter - コンバーター。

  • メソッドの詳細

    • process

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

    • close

      public void close()