т.е. например, у меня есть постгрес, из него надо потоком лить данные на скульный dwh. есть какое-то приложение, которое постоянно дергает данные из постгри, кладет в очередь, откуда их что-то забирает и кладет в dwh?
или там как-то транзакционный журнал реплицируется как-то по-хитрому? просто мы так с помощью cdc из сиквела лили в оракл. тоже типа консолидация
Есть тулзы для чтения WAL постгреса, потом можно в очередь и далее куда дальше надо.