У меня есть сценарий, в котором мне нужно запустить одно Java-задание Apache Beam в двух разных средах (одна находится в облаке Google, который читает из pubsub, другая - во Flink, который читает из Кафки).Как я могу кодировать уровень абстракции через параметры конвейера, чтобы добиться этого.