DSL Kafka Streams Разделение потока предиката

Question

branch(new predicate{
 business logic 
 if(condition)
   return true
 else
   return false;

Когда условие ложно, как нажать на другой поток.В настоящее время создается другой предикат, который собирает все другие записи, которые не удовлетворяют вышеуказанному предикату в цепочке.Есть ли способ сделать в том же предикате?

Answer 1

для этого вам нужно также передать второй предикат, который всегда возвращает true

KStream<String, String>[] branches = kStream.branch(
    yourPredicate, 
    (String key, String value) -> true
);
branches[0].to(firstTopic);
branches[1].to(secondTopic);