spring - spring-xd 如何使用多处理器创建流

Question

我有一个问题是如何使用多处理器创建流。例如：

stream create --name multiModuleTest --definition "tcp | processor1 | processor2 |file" --deploy

或者

stream create --name multiModuleTest --definition "(tcp, http) | processor1 | processor2 | (file,log)" --deploy

请告诉我该怎么做？谢谢 ！

Answer 1

Fire up multiple containers and use the deployment manifest to set the module count.

If you want to multiprocess within a processor instance, change the input channel to an ExecectorChannel. Docs here and here.