クラス KafkaStreamBrancher<K,V>

java.lang.ObjectSE
org.springframework.kafka.support.KafkaStreamBrancher<K,V>
型パラメーター:
K - キーの種類
V - 値の型
public final class KafkaStreamBrancher<K,V> extends ObjectSE
Kafka ストリームプロセッサートポロジで branches を構築するためのメソッドチェーン方法を提供します。

使用例:

 
 new KafkaStreamBrancher<String, String>()
    .branch((key, value) -> value.contains("A"), ks->ks.to("A"))
    .branch((key, value) -> value.contains("B"), ks->ks.to("B"))
    //default branch should not necessarily be defined in the end
    .defaultBranch(ks->ks.to("C"))
    .onTopOf(builder.stream("source"))
導入:
2.2.4
作成者:
Ivan Ponomarev, Artem Bilan, Soby Chacko

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

    • KafkaStreamBrancher

      public KafkaStreamBrancher()

  • メソッドの詳細

    • branch

      public KafkaStreamBrancher<K,V> branch(org.apache.kafka.streams.kstream.Predicate<? super K, ? super V> predicate, ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K,V>> consumer)
      新しいブランチを定義します。
      パラメーター:
      predicate - Predicate インスタンス
      consumer - このブランチの KStream のコンシューマー
      戻り値:
      this

    • defaultBranch

      public KafkaStreamBrancher<K,V> defaultBranch(ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K,V>> consumer)
      デフォルトのブランチを定義します。他のブランチにディスパッチされなかったすべてのメッセージは、このストリームに送信されます。このメソッドは、チェーンの最後で必ずしも呼び出す必要はありません。
      パラメーター:
      consumer - このブランチの KStream のコンシューマー
      戻り値:
      this

    • onTopOf

      public org.apache.kafka.streams.kstream.KStream<K,V> onTopOf(org.apache.kafka.streams.kstream.KStream<K,V> stream)
      与えられた KStream の上に ブランチを構築する終了メソッド。各述語 - コンシューマーのペアを順に適用し、ブランチを作成します。デフォルトのコンシューマーが存在する場合、どの述語にも一致しないすべてのレコードがデフォルトのコンシューマーによって処理されます。
      パラメーター:
      stream - 分割する KStream 
      戻り値:
      処理されたストリーム
      例外:
      NullPointerExceptionSE - ストリームが null の場合
      IllegalStateExceptionSE - 述語の数がコンシューマーの数と一致しない場合