class KStreamTransform implements ProcessorSupplier<K, V> {

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

    public  KStreamTransform(TransformerSupplier<K, V, KeyValue<K1, V1>> transformerSupplier);

}