[Source-Postgres] : Add invalid replication slot config error (#43945)

Author: akashkulk

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

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"),
+            ),
+        )
     }
 }

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.                                                                                                                    |