クラス KafkaStreamBrancher<K,V>
java.lang.ObjectSE
org.springframework.kafka.support.KafkaStreamBrancher<K,V>
- 型パラメーター:
K
- キーの種類V
- 値の型
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
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明branch
(org.apache.kafka.streams.kstream.Predicate<? super K, ? super V> predicate, ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K, V>> consumer) 新しいブランチを定義します。defaultBranch
(ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K, V>> consumer) デフォルトのブランチを定義します。指定されたKStream
の上にブランチを構築する終了メソッド。
コンストラクターの詳細
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
- 戻り値:
- 提供されたストリーム