У меня есть два бесконечных потока данных kafka в одном задании flink, например:
StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream kafka1 = ...
DataStream kafka2 = ...
kafka1.process();
kafka2.process();
environment.execute();
Параллельно или последовательно выполняется процесс двух потоков