我最近开始学习流处理，现在正在尝试apache flink。我正在尝试编写一个作业，从kafka主题中读取事件，可能执行一些无状态链式转换，并对另一个应用程序进行rest调用以发布每个转换的事件。例如，我的main方法可以如下所示-

public class KafkaSourceToRestSinkJob {
    public static void main(String[] args) {
        String configPath = args[0];
        //Read configuration for the job (like kafka properties, rest uri for sink, possibly operators to invoke)
        ...
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<String> dataStream = env.addSource(new FlinkKafkaConsumer<>(topic, new SimpleStringSchema(), kafkaProps));
        dataStream.addSink(new RestSinkFunction<>()); //Custom sink function implementing org.apache.flink.streaming.api.functions.sink.SinkFunction
        //Chain some operators depending on some parameters in the config file
        ...
        env.execute("Confused Job");
    }
}

我的目标是为具有相同源和汇类型的多个作业提供一个公共jar工件。如果我需要一个作业来执行转换a、b和c（实现将出现在jar中），我可以在配置文件中指定它们，并在程序args中传递文件的路径。
下面是我的问题-
是否可以动态调用运算符？
我知道在接收器中进行rest调用可能会导致一些不必要的延迟，但在我的应用程序中，这是可以忍受的。我也不在乎回应。记住这一点，我有理由避免休息池吗？
总的来说，我是不是大错特错了？
谢谢您！