class KStreamFlatMap implements ProcessorSupplier<K, V> {

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

      KStreamFlatMap(KeyValueMapper<K, V, Iterable<KeyValue<K1, V1>>> mapper);

}