使用反映解决了这个问题，下面是解决这个问题的程式码。
注意：这要求我知道完全限定类名和方法名的列表沿着它们的参数。

@Component
public class SampleJobExecutor extends ProcessFunction<String, String> {

@Autowired
MyAppProperties myAppProperties;

    @Override
    public void processElement(String inputMessage, ProcessFunction<String, String>.Context context,
            Collector<String> collector) throws Exception {
        
        String className = null;
        String methodName = null;
        try {   
            
            Map<String, List<String>> map = myAppProperties.getMapOfImplementors();
            
            JSONObject json = new JSONObject(inputMessage);
            if (json != null && json.has("appName")) {
                className = map.get(json.getString("appName")).get(0);
                methodName = map.get(json.getString("appName")).get(1);
            }
            
            
            Class<?> forName = Class.forName(className);
            Object job = forName.newInstance();
            Method method = forName.getDeclaredMethod(methodName, String.class);
            method.invoke(job , inputMessage);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }