【发布时间】：2023-03-20 07:52:02
【问题描述】：
我想创建一个包含 4 个 tkafkainputs 的流，以培养 4 个消费者，但是当我将每个消费者与 onComponentok 和 tkafkaconnection 连接时，作业运行时只会创建一个。
我怎样才能做到这一点？
更新：
我试过tparallelize，但没用。尽管tkafkainputs 配置为保持打开状态50 分钟，但几秒钟后作业结束。我也尝试了tparallelize 和 4 trunjobs，但发生了与上面相同的事情。
【问题讨论】：
-
如果您从事 talend entreprise 工作，您是否尝试过使用 tparallelize 组件？
-
@AmineBenKhelifa 在 tkafkaconnection 之后添加 tparallelize ？
-
是的！然后删除所有onComponentok并与parallezation匹配 tkafkaconnection-->OncomponentOK --> tparallelize --> tkafkainput1
-
或使用 onsubjobOk 其他 oncomponentOk ！
-
您将有机会更新您的问题并添加您的第二个问题并开发问题以便我们提供帮助
标签： talend