将输入运算符动态添加到正在运行的 Apache Apex 应用程序中

Question

是否可以在正在运行的 Apex 应用程序中为不同的源添加输入运算符？例如：在生产环境中，我正在运行一个 Apex 应用程序以从输入源读取文本文件，并且我想将 Kafka 源及其输入运算符添加到同一 DAG 中。

Answer 1

Priyanshu，可以有多个输入运算符。只需将 kafka 输入运算符添加到您的 dag。

http://docs.datatorrent.com/library_operators/

阿莫尔