Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2363

Support pg_logical_emit_message

    XMLWordPrintable

Details

    Description

      This function is used to write arbitrary messages into the WAL that can then be read by logical decoding plugins. This is very useful to transactionally produce messages to Kafka. It's also a really great way to heartbeat and advance replication slots for databases with low write volume. This is currently supported by wal2json, but isn't supported by pgoutput yet. Here are some example payloads from wal2json: https://github.com/eulerto/wal2json/blob/master/expected/message.out

      Attachments

        Activity

          People

            Unassigned Unassigned
            rjkrage1 Ryan Krage (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            7 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: