Нури, нужен инструмент CDC (Change data capture) для извлечения изменений из базы данных.Инструментарий CDC зависит от базы данных, так как опирается на внутреннюю часть соответствующей БД (например, журнал транзакций).Там нет одного общего решения.Другой подход может заключаться в использовании пользовательских триггеров базы данных для извлечения и публикации изменений, внесенных в таблицу базы данных.В любом случае, изменения публикуются в промежуточном программном обеспечении для обмена сообщениями (Kafka, JMS, Hazelcast, где Jet может их забрать и обработать.