У меня есть 2 потока, как показано ниже, и транспорт - кролик
stream1 source|processor|processor>namedchannel
stream2 namedchannel>processor|processor|sink
Я вижу, что много сообщений забито в именованном канале, и мне нравится получать больше сообщений из именованного канала. Для исходных и процессорных модулей я увеличил параллелизм, но я не уверен, что нужно сделать для именованного канала.
Установите параллелизм на первом модуле (processor)...
xd:>stream create foo --definition "time > queue:foo" --deploy
Created and deployed new stream 'foo'
xd:>stream create bar --definition "queue:foo > log"
Created new stream 'bar'
xd:>stream deploy bar --properties module.log.consumer.concurrency=2
Deployed stream 'bar'
В настоящее время вы не можете установить параллелизм на именованном канале topic: — это исправлено в версии 1.3.1, которая скоро появится.
