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

クラス 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

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

    • 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 
      戻り値:
      提供されたストリーム