Я использую шаг Kafka Consumer в PDI v8.2. Поскольку этот шаг выполняется постоянно, в документации Pentaho предлагается использовать шаг Abort для периодической остановки процесса. Я ищу некоторые предложения о том, как / где осуществить прерывание.
В целях планирования я бы предпочел использовать время в качестве условия прерывания, чтобы я мог легко планировать выполнение задания через регулярные промежутки времени и знать, что оно еще не запущено. Я пытался сделать это в рамках основной родительской работы. Я добавил цикл и условие, чтобы прервать работу через 10 минут. Но поскольку поток заданий является последовательным, после входа в шаг потребителя Kafka он никогда не возвращается с этого непрерывно работающего шага, чтобы завершить цикл и оценить время выполнения.
Я могу прервать процесс в суб-преобразовании, если смогу выяснить, как периодически проверять условие времени. Однако шаги преобразования не допускают циклов и имеют меньше возможностей для условной логики.
У кого-нибудь есть пример того, как им удалось реализовать прерывание в потоковой передаче PDI Kafka Consumer?