diff --git a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java index 192044a2aea0..a68b40adda2a 100644 --- a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java +++ b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java @@ -92,7 +92,10 @@ public static AirbyteStream addCdcMetadataColumns(final AirbyteStream stream) { /** * Modifies streams that are NOT present in the publication to be full-refresh only streams. Users * should be able to replicate these streams, just not in incremental mode as they have no - * associated publication. Previously, we also setSourceDefinedCursor(false) and setSourceDefinedPrimaryKey(List.of()) for streams that are in the catalog but not in the CDC publication, but now that full refresh streams can be resumable, we should include this information. + * associated publication. Previously, we also setSourceDefinedCursor(false) and + * setSourceDefinedPrimaryKey(List.of()) for streams that are in the catalog but not in the CDC + * publication, but now that full refresh streams can be resumable, we should include this + * information. */ public static AirbyteStream setFullRefreshForNonPublicationStreams(final AirbyteStream stream, final Set publicizedTablesInCdc) {