class KStreamBranch implements ProcessorSupplier<K, V> {

    @SuppressWarnings("unchecked")
    public KStreamBranch(Predicate<K, V> ... predicates) {
        this.predicates = predicates;
    }

    @SuppressWarnings("unchecked") public  KStreamBranch(Predicate<K, V> ... predicates);

}