Skip to content

Commit

Permalink
[source-postgres] use Debezium 3.0.1 and increase MAX_FIRST_RECORD_WA…
Browse files Browse the repository at this point in the history
…IT_TIME (#48495)
  • Loading branch information
theyueli authored Dec 21, 2024
1 parent b5bfd0c commit d02c1ea
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 4 deletions.
4 changes: 2 additions & 2 deletions airbyte-integrations/connectors/source-postgres/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ application {

dependencies {
implementation 'commons-codec:commons-codec:1.16.0'
implementation 'io.debezium:debezium-embedded:2.6.2.Final'
implementation 'io.debezium:debezium-connector-postgres:2.6.2.Final'
implementation 'io.debezium:debezium-embedded:3.0.1.Final'
implementation 'io.debezium:debezium-connector-postgres:3.0.1.Final'

testFixturesApi 'org.testcontainers:postgresql:1.19.0'

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ data:
connectorSubtype: database
connectorType: source
definitionId: decd338e-5647-4c0b-adf4-da0e75f5a750
dockerImageTag: 3.6.25
dockerImageTag: 3.6.26
dockerRepository: airbyte/source-postgres
documentationUrl: https://docs.airbyte.com/integrations/sources/postgres
githubIssueLabel: source-postgres
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ public class PostgresUtils {
private static final String PGOUTPUT_PLUGIN = "pgoutput";

public static final Duration MIN_FIRST_RECORD_WAIT_TIME = Duration.ofMinutes(2);
public static final Duration MAX_FIRST_RECORD_WAIT_TIME = Duration.ofMinutes(40);
public static final Duration MAX_FIRST_RECORD_WAIT_TIME = Duration.ofMinutes(120);
public static final Duration DEFAULT_FIRST_RECORD_WAIT_TIME = Duration.ofMinutes(20);
public static final Duration DEFAULT_SUBSEQUENT_RECORD_WAIT_TIME = Duration.ofMinutes(1);

Expand Down
1 change: 1 addition & 0 deletions docs/integrations/sources/postgres.md
Original file line number Diff line number Diff line change
Expand Up @@ -329,6 +329,7 @@ According to Postgres [documentation](https://www.postgresql.org/docs/14/datatyp

| Version | Date | Pull Request | Subject |
|---------|------------|----------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| 3.6.26 | 2024-12-20 | [48495](https://github.com/airbytehq/airbyte/pull/48495) | Increase MAX_FIRST_RECORD_WAIT_TIME and use Debezium 3.0.1 |
| 3.6.25 | 2024-12-17 | [49838](https://github.com/airbytehq/airbyte/pull/49838) | Use a base image: airbyte/java-connector-base:1.0.0 |
| 3.6.24 | 2024-12-16 | [49469](https://github.com/airbytehq/airbyte/pull/49469) | Simplify CTID_TABLE_BLOCK_SIZE query for Postgres integration |
| 3.6.23 | 2024-11-13 | [\#48482](https://github.com/airbytehq/airbyte/pull/48482) | Convert large integer typed using NUMERIC(X, 0) into a BigInteger. l
Expand Down

0 comments on commit d02c1ea

Please sign in to comment.