クラスの使用
org.springframework.kafka.support.KafkaStreamBrancher
org.springframework.kafka.support 内の KafkaStreamBrancher 使用
修飾子と型メソッド説明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.defaultBranch
(ConsumerSE<? super org.apache.kafka.streams.kstream.KStream<K, V>> consumer) デフォルトのブランチを定義します。