class KTableSource implements ProcessorSupplier<K, V> {

    @Override
    public Processor<K, V> get() {
        return materialized ? new MaterializedKTableSourceProcessor() : new KTableSourceProcessor();
    }

    public  KTableSource(String topic);

}