class KStreamFlatTransform implements ProcessorSupplier<KIn, VIn> {

    @Override
    public Processor<KIn, VIn> get() {
        return new KStreamFlatTransformProcessor<>(transformerSupplier.get());
    }

    public  KStreamFlatTransform(final TransformerSupplier<? super KIn, ? super VIn, Iterable<KeyValue<KOut, VOut>>> transformerSupplier);

}