class KTableReduce implements KTableProcessorSupplier<K, V, V> {

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

      KTableReduce(final String storeName, final Reducer<V> addReducer, final Reducer<V> removeReducer);

}