Ограничение количества приемников для топологии API процессора - PullRequest
0 голосов
/ 17 июня 2020

Используя 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 .... синкн), который может быть добавили в топологию?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...