On Wed, Jun 24, 2026 at 3:02 AM Masahiko Sawada <[email protected]> wrote: > Right. I'm implementing a basic DDL replication solution using this > hook as a sample implementation. Other than that, this feature can be > used to add additional information for the replicated transaction that > is not replicated via logical replication protocol, such as the > executed user or context-specific information, which can then be > dispatched to a CDC system connected to the subscriber.
+1 for the proposed hook, although I haven't read the patch yet. I know of a system that uses logical decoding messages to propagate data to external systems. In that system, the application writes the data to be propagated as logical decoding messages, and a CDC pipeline consumes them via logical decoding and sends them to other systems, for example through Kafka. In that system, when the remote site is maintained by physical replication, the same logical decoding messages can be decoded on the standby at the remote site to deliver them to external systems there. However, if the remote site uses logical replication instead, those messages are currently neither delivered to nor processed on the subscriber at the remote site. As a result, the CDC pipeline at the remote site cannot consume the data they carry. The proposed hook might be useful for this use case. An extension could process the incoming logical decoding messages on the subscriber and forward them to the local CDC pipeline, or store or re-emit them in a form that local consumers can process. Regards, -- Fujii Masao
