Debezium Connector: фиксируйте изменения, начиная с определенного SCN
Интересно, могу ли я начать перехватывать изменения из конкретного Oracle SCN с помощью Debezium Connector (с включенным LogMiner), в официальной спецификации указаны только два свойства, которые я могу настроить:
log.mining.scn.gap.detection.gap.size.min - Specifies the minimum gap size. (Default - 1000000)
log.mining.scn.gap.detection.time.interval.max.ms - Specifies the maximum time interval. (Default - 20000)
Значит, нет SCN как точки, с которой я могу начать репликацию, или я что-то упускаю?
В качестве примера, что я пытаюсь сделать, так это найти решение, когда имея снапшот Oracle №1, я могу полностью загрузить и преобразовать все данные в другую базу данных с помощью специальных инструментов. Всякий раз, когда я получаю другой, новый, обновленный снимок №2, используемый инструмент не соответствует требованиям для репликации дельты между снимками 1 и 2, и необходимо найти другой подход. Вероятно, здесь может помочь Debezium как инструмент с открытым исходным кодом.
Обходной путь, который первым приходит на ум, — запустить Debezium с начальной загрузкой, до окончания снапшота №1, затем перезапустить процесс Debezium уже со снапшотом №2 в качестве источника и реплицировать все данные через Kafka и Sink Connector в целевую базу данных .
Есть ли какие-то подводные камни, которых я не вижу на данный момент?