Adding Input Operator Dynamically to a running Apache Apex application

Question

Is it possible to add input operator for different source in the running Apex application? For example: In an production environment, I am running an Apex application to read the text-file from input source and I want to add Kafka source with its input operator to the same DAG.

score 3 · Answer 1 · answered Apr 14 '17 at 00:25

3

Priyanshu, You can have multiple input operators. Just add kafka input operator to you dag.

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

Amol

answered Apr 14 '17 at 00:25

amol kekre

31
1

Adding Input Operator Dynamically to a running Apache Apex application

1 Answers1