クラス org.springframework.kafka.support.KafkaStreamBrancher の使用 (Spring for Apache Kafka API) - Javadoc

KafkaStreamBrancher を使用するパッケージ

パッケージ

説明

org.springframework.kafka.support

kafka サポート用パッケージ

org.springframework.kafka.support 内の KafkaStreamBrancher 使用
KafkaStreamBrancher を返す org.springframework.kafka.support のメソッド
修飾子と型
メソッド
説明
KafkaStreamBrancher<K,V>
KafkaStreamBrancher.branch(org.apache.kafka.streams.kstream.Predicate<? super K, ? super V> predicate, ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K,V>> consumer)
新しいブランチを定義します。
KafkaStreamBrancher<K,V>
KafkaStreamBrancher.defaultBranch(ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K,V>> consumer)
デフォルトのブランチを定義します。