class KStreamFlatMap implements ProcessorSupplier<K, V> {

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

      KStreamFlatMap(final KeyValueMapper<? super K, ? super V, ? extends Iterable<? extends KeyValue<? extends K1, ? extends V1>>> mapper);

}