Решение с открытым исходным кодом Вы можете использовать инструмент интеграции Confluent Kafka для отслеживания операций вставки и обновления с использованием метки времени загрузки.Они автоматически предоставят вам данные в реальном времени, которые будут вставлены или обновлены в базе данных.Если у вас есть мягкое удаление в вашей базе данных, это также можно отследить, используя отметку времени загрузки и активный или неактивный флаг.Если таких флагов нет, вам нужно предоставить некоторую логику, в которой раздел может быть обновлен в этот день, и отправить весь этот раздел в поток, что, безусловно, является исчерпывающим ресурсом.
Платное решение Существует платный инструмент под названием Striim CDC , который может предоставлять ответы в вашей системе в режиме реального времени