Используя API процессора kafka (не DSL), ниже приведено описание топологии:
import org.apache.kafka.streams.Topology;
Topology topology = new Topology();
topology.addSource("mySource", "source_topic_name");
topology.addProcessor("StreamProcessor",()->new StreamProcessor(), "mySource");
topology.addSink("sink1","TargetTopic1","StreamProcessor");
topology.addSink("sink2","TargetTopic2","StreamProcessor");
Каков максимальный предел для количества приемников (приемник1, приемник2 .... синкн), который может быть добавили в топологию?