Как выполнить изящное отключение трубопровода Apache Beam

#apache-spark #apache-beam #apache-beam-io #apache-beam-kafkaio Вопрос: У меня есть конвейер Apache Beam, работающий на Spark. Конвейер считывает данные из темы Кафки (KafkaIO) и записывает их в файлы (FileIO). Время от времени…