Как правильно использовать логическую репликацию PostgreSQL?

Что, в сети прям ни одной статьи про это нет и для тебя персонально нужно написать оную?

Да, если можно

Сколько платишь?

Однозначно звучит как проблема XY.

так – неправильно

Есть немного.
Ну оригинальная проблема такая - есть сервис с postgres-ом из него надо вытащить (и постоянно синхронизировать) часть данных, через API тянуть долго

ну от содержания зависит
предварительно нисколько

Мне кажется, что репликация может сработать, но лично я сам не делал репликацию, поэтому углубляться не буду.

Альтернативное решение (чтобы не таскать через API) — синхронизировать данные через очередь сообщений.

Почему?
Как лучше?

делай через кафку. а так если там они для какой-нибудь батч обработки, то можно хоть скриптом перегонять.

ну тяни быстрее

ok

По поводу очередей: существуют прямо готовые решения, чтобы из лога PostgreSQL слать данные в Kafka. Точно видел такое, но гуглить сейчас некогда.

https://debezium.io/

Давно пора было прикрыть этот рассадник порока – Тор. РКН – Ван лав. Слава императору. Слава Северному Вьетнаму.

Ага, ещё точно видел другое альтернативное решение, не на жабе написанное.

Нормально работает. Были грабли с INSERT …. SELECT:

INSERT INTO table FROM SELECT * .... ORDER BY RAND() LIMIT 10

А как именно проявлялись?

Я хоть и не автор, но отвечу: очевидно же, что при логической репликации в результате выполнения таких (странных) запросов, на мастере и слейве получатся таблицы с разным содержимым.

Всегда-ли? А если таблица из которой делается select тоже реплецируется?
Я вобще подумал, что может быть что репликация такие запрос вобще не отправляет

А как именно проявлялись?

Совершенно правильно написал emorozov, что содержимое таблиц получалось разным.

Это же логическая репликация, RAND() разные результаты вернёт на обеих базах, соотв-но и вставятся разные строки.