向正在运行的apacheapex应用程序动态添加输入运算符

50pmv0ei  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(376)

是否可以在运行的apex应用程序中为不同的源添加输入运算符?例如:在一个生产环境中,我运行一个apex应用程序从输入源读取文本文件,我想将kafka源及其输入操作符添加到同一个dag中。

1bqhqjot

1bqhqjot1#

priyanshu,可以有多个输入运算符。只需添加Kafka输入运算符到您的dag。
http://docs.datatorrent.com/library_operators/
阿米尔

相关问题