apache-kafka - 実行中の Apache Apex アプリケーションに入力演算子を動的に追加する

Question

実行中の Apex アプリケーションで別のソースの入力演算子を追加することはできますか? 例: 本番環境で、Apex アプリケーションを実行して入力ソースからテキスト ファイルを読み取り、Kafka ソースをその入力演算子とともに同じ DAG に追加したいと考えています。