Skip to content
This repository has been archived by the owner on Jan 29, 2024. It is now read-only.

Commit

Permalink
Merge pull request #2038 from aiven/cdc-pg-flink
Browse files Browse the repository at this point in the history
Added notes about the publication name in Flink PG CDC connector
  • Loading branch information
harshini-rangaswamy authored Nov 13, 2023
2 parents 18e6981 + 67a33fa commit 689ace7
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions docs/products/flink/howto/pg-cdc-connector.rst
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,10 @@ Where:
* ``database-name``: The name of the database where the source table resides, which is set to ``defaultdb`` in the example.
* ``decoding.plugin.name``: The decoding plugin to be used by the CDC connector, which is set to ``pgoutput`` in the example.

.. Note::

The PostgreSQL CDC connector will use or create a publication named ``dbz_publication`` tracking the changes of one or more tables. Therefore, the publication must already exist in PostgreSQL, or the connecting user must have enough privileges to create it.

8. Select **Next** to add the sink table, and then select **Add your first sink table**. Select *Aiven for Apache Kafka®* as the integrated service from the drop-down list.
9. In the **Table SQL** section, input the SQL statement for creating the sink table where the PostgreSQL CDC connector will send the data. Select **Add table**.
10. In the **Create statement** section, write the SQL schema that defines the fields retrieved from the PostgreSQL® table and any additional transformations.
Expand Down Expand Up @@ -103,6 +107,8 @@ If you encounter the ``must be superuser to create FOR ALL TABLES publication``
'INSERT,UPDATE,DELETE'
);
.. Note::

The publication name must be ``dbz_publication`` for the PostgreSQL CDC connector to work


0 comments on commit 689ace7

Please sign in to comment.