From 22c102d1760689f10d155045e1021f70dc8e60e1 Mon Sep 17 00:00:00 2001 From: Francesco Date: Thu, 27 Jul 2023 09:37:41 +0200 Subject: [PATCH 1/4] Added notes about the publication name --- docs/products/flink/howto/pg-cdc-connector.rst | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/docs/products/flink/howto/pg-cdc-connector.rst b/docs/products/flink/howto/pg-cdc-connector.rst index 16bbdb623c..7a64c510ab 100644 --- a/docs/products/flink/howto/pg-cdc-connector.rst +++ b/docs/products/flink/howto/pg-cdc-connector.rst @@ -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 either the publication need to already exist in PostgreSQL or the connecting user needs to have enough priviledges 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. @@ -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 From 4a569445f2f9f02c2365c25ca129139b1bf63735 Mon Sep 17 00:00:00 2001 From: Francesco Date: Fri, 4 Aug 2023 10:43:28 +0200 Subject: [PATCH 2/4] fixed error --- docs/products/flink/howto/pg-cdc-connector.rst | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/products/flink/howto/pg-cdc-connector.rst b/docs/products/flink/howto/pg-cdc-connector.rst index 7a64c510ab..df78161869 100644 --- a/docs/products/flink/howto/pg-cdc-connector.rst +++ b/docs/products/flink/howto/pg-cdc-connector.rst @@ -28,7 +28,7 @@ In addition to the above, gather the following information about the source Post * ``Decoding plugin name``: The decoding plugin name to use for capturing the changes. For PostgreSQL CDC, set it as ``pgoutput``. .. important:: - To create a PostgreSQL CDC source connector in Aiven for Apache Flink with Aiven for PostgreSQL using the pgoutput plugin, you need to have superuser privileges. For more information, see :ref:`Troubleshooting`. + To create a PostgreSQL CDC source connector in Aiven for Apache Flink with Aiven for PostgreSQL using the pgoutput plugin, you need to have superuser priviledges. For more information, see :ref:`Troubleshooting`. Configure the PostgreSQL CDC connector @@ -109,6 +109,6 @@ If you encounter the ``must be superuser to create FOR ALL TABLES publication`` .. Note:: - The publication name must be `dbz_publication` for the PostgreSQL CDC connector to work + The publication name must be ``dbz_publication`` for the PostgreSQL CDC connector to work From fa9d84be1d75df9c4badc524d99d6fd90ab13ebe Mon Sep 17 00:00:00 2001 From: Francesco Date: Fri, 4 Aug 2023 10:49:34 +0200 Subject: [PATCH 3/4] fixed --- docs/products/flink/howto/pg-cdc-connector.rst | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/products/flink/howto/pg-cdc-connector.rst b/docs/products/flink/howto/pg-cdc-connector.rst index df78161869..87273d9fee 100644 --- a/docs/products/flink/howto/pg-cdc-connector.rst +++ b/docs/products/flink/howto/pg-cdc-connector.rst @@ -28,7 +28,7 @@ In addition to the above, gather the following information about the source Post * ``Decoding plugin name``: The decoding plugin name to use for capturing the changes. For PostgreSQL CDC, set it as ``pgoutput``. .. important:: - To create a PostgreSQL CDC source connector in Aiven for Apache Flink with Aiven for PostgreSQL using the pgoutput plugin, you need to have superuser priviledges. For more information, see :ref:`Troubleshooting`. + To create a PostgreSQL CDC source connector in Aiven for Apache Flink with Aiven for PostgreSQL using the pgoutput plugin, you need to have superuser privileges. For more information, see :ref:`Troubleshooting`. Configure the PostgreSQL CDC connector @@ -77,7 +77,7 @@ Where: .. Note:: - The PostgreSQL CDC connector will use or create a publication named ``dbz_publication`` tracking the changes of one or more tables. Therefore either the publication need to already exist in PostgreSQL or the connecting user needs to have enough priviledges to create it. + The PostgreSQL CDC connector will use or create a publication named ``dbz_publication`` tracking the changes of one or more tables. Therefore either the publication need to already exist in PostgreSQL or the connecting user needs to 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**. From 67a33fa31bf7496c5a26c3b121e41464ad898cc3 Mon Sep 17 00:00:00 2001 From: Harshini Rangaswamy <108724024+harshini-rangaswamy@users.noreply.github.com> Date: Mon, 13 Nov 2023 16:27:21 +0100 Subject: [PATCH 4/4] Update docs/products/flink/howto/pg-cdc-connector.rst --- docs/products/flink/howto/pg-cdc-connector.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/products/flink/howto/pg-cdc-connector.rst b/docs/products/flink/howto/pg-cdc-connector.rst index 87273d9fee..79de4cb797 100644 --- a/docs/products/flink/howto/pg-cdc-connector.rst +++ b/docs/products/flink/howto/pg-cdc-connector.rst @@ -77,7 +77,7 @@ Where: .. Note:: - The PostgreSQL CDC connector will use or create a publication named ``dbz_publication`` tracking the changes of one or more tables. Therefore either the publication need to already exist in PostgreSQL or the connecting user needs to have enough privileges to create it. + 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**.