From 421c7b34b1dde2d80e712bc171e24773830a8048 Mon Sep 17 00:00:00 2001
From: Akash Kulkarni <113392464+akashkulk@users.noreply.github.com>
Date: Mon, 12 Aug 2024 15:50:57 -0700
Subject: [PATCH] [Source-Postgres] : Add invalid replication slot config error
 (#43945)

---
 .../connectors/source-postgres/metadata.yaml        |  2 +-
 .../postgres/PostgresSourceExceptionHandler.kt      | 13 +++++++++++++
 docs/integrations/sources/postgres.md               |  5 +++--
 3 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/airbyte-integrations/connectors/source-postgres/metadata.yaml b/airbyte-integrations/connectors/source-postgres/metadata.yaml
index f79c07137f703..88ddcfb95fb2f 100644
--- a/airbyte-integrations/connectors/source-postgres/metadata.yaml
+++ b/airbyte-integrations/connectors/source-postgres/metadata.yaml
@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: decd338e-5647-4c0b-adf4-da0e75f5a750
-  dockerImageTag: 3.6.14
+  dockerImageTag: 3.6.15
   dockerRepository: airbyte/source-postgres
   documentationUrl: https://docs.airbyte.com/integrations/sources/postgres
   githubIssueLabel: source-postgres
diff --git a/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceExceptionHandler.kt b/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceExceptionHandler.kt
index 42d2de2566bc0..2e75891d37a9c 100644
--- a/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceExceptionHandler.kt
+++ b/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceExceptionHandler.kt
@@ -160,5 +160,18 @@ class PostgresSourceExceptionHandler : ConnectorExceptionHandler() {
                     ),
             ),
         )
+
+        add(
+            ConnectorErrorProfile(
+                errorClass = "Postgres Debezium Connection Error",
+                regexMatchingPattern = ".*cannot read from logical replication slot.*",
+                failureType = FailureType.CONFIG,
+                externalMessage =
+                    "The configured replication slot has been dropped or has corrupted. Please recreate the replication slot.",
+                sampleInternalMessage =
+                    "org.postgresql.util.PSQLException: ERROR: cannot read from logical replication slot \"airbyte_slot\"",
+                referenceLinks = listOf("https://github.com/airbytehq/oncall/issues/5981"),
+            ),
+        )
     }
 }
diff --git a/docs/integrations/sources/postgres.md b/docs/integrations/sources/postgres.md
index 5d7183b212c64..f61935922a721 100644
--- a/docs/integrations/sources/postgres.md
+++ b/docs/integrations/sources/postgres.md
@@ -311,8 +311,9 @@ According to Postgres [documentation](https://www.postgresql.org/docs/14/datatyp
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                                                                    |
 |---------|------------|----------------------------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| 3.6.14  | 2024-08-08 | [43418](https://github.com/airbytehq/airbyte/pull/43418)   | Adopt latest CDK.                                                                                                                                          |
-| 3.6.13  | 2024-07-30 | [42869](https://github.com/airbytehq/airbyte/pull/42869)   | Adopt latest CDK.                                                                                                                                          |
+| 3.6.15  | 2024-08-12 | [43945](https://github.com/airbytehq/airbyte/pull/43945)   | Add missing replication slot config error.                                                                                                                                 |
+| 3.6.14  | 2024-08-08 | [43418](https://github.com/airbytehq/airbyte/pull/43418)   | Adopt latest CDK.                                                                                                                                                          |
+| 3.6.13  | 2024-07-30 | [42869](https://github.com/airbytehq/airbyte/pull/42869)   | Adopt latest CDK.                                                                                                                                                          |
 | 3.6.12  | 2024-07-30 | [42550](https://github.com/airbytehq/airbyte/pull/42550) | Correctly report stream states.                                                                                                                                            |
 | 3.6.11  | 2024-07-29 | [42852](https://github.com/airbytehq/airbyte/pull/42852) | Bump CDK version to latest to use new bug fixes on error translation.                                                                                                      |
 | 3.6.10  | 2024-07-23 | [42417](https://github.com/airbytehq/airbyte/pull/42417) | Handle null error message in ConnectorExceptionHandler.                                                                                                                    |