отсылаться сообщения, записанные через pg_logical_emit_message?
Если я создаю слот через pg_create_logical_replication_slot('demo_slot', 'test_decoding');, то в него попадают эти сообщения (согласно SELECT * FROM pg_logical_slot_peek_changes('demo_slot', NULL, NULL);, а в созданный CREATE_REPLICATION_SLOT main_slot LOGICAL pgoutput NOEXPORT_SNAPSHOT — нет, хотя онлайн вроде есть примеры в которых эти сообщения вполне должны уходить через pgoutput. При этом INSERT попадает в оба слота
Если кто-то будет искать подобное, то в START_REPLICATION SLOT ... LOGICAL 0/0 [options] нужно указать опцию messages
Обсуждают сегодня