class KStreamForeach implements ProcessorSupplier<K, V> {

    @Override
    public Processor<K, V> get() {
        return new KStreamForeachProcessor();
    }

    public  KStreamForeach(ForeachAction<K, V> action);

}