old CDK: update logging to avoid duplicate messages (mssql & postgres sources) + revert initial load timeout back to 4h (#60251)

Author: yardencarmeli

airbyte-cdk/java/airbyte-cdk/README.md

@@ -174,6 +174,7 @@ corresponds to that version.
 
 | Version    | Date       | Pull Request                                                | Subject                                                                                                                                                        |
 |:-----------|:-----------|:------------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 0.48.14    | 2025-05-15  | [\#60251](https://github.com/airbytehq/airbyte/pull/60251)  | Improve logging by reducing redundant log statements.                                                                                                                                      |
 | 0.48.13    | 2025-05-06 | [\#59682](https://github.com/airbytehq/airbyte/pull/59682)  | Reduce initial load timeout and improve logging.                                                                                                               |
 | 0.48.9     | 2025-04-17 | [\#58132](https://github.com/airbytehq/airbyte/pull/58132)  | Fix vulnerability in dependencies.                                                                                                                             | 
 | 0.48.8     | 2025-03-11 | [\#55709](https://github.com/airbytehq/airbyte/pull/55709)  | Filter unwanted tables in discover to prevent null table issues                                                                                                |

airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties

@@ -1 +1 @@
-version=0.48.13
+version=0.48.14

airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIterator.kt

@@ -45,6 +45,9 @@ class DebeziumRecordIterator<T>(
     private val heartbeatEventSourceField: MutableMap<Class<out ChangeEvent<*, *>?>, Field?> =
         HashMap(1)
     private val subsequentRecordWaitTime: Duration = firstRecordWaitTime.dividedBy(2)
+    init {
+        LOGGER.info { "Starting CDC Process" }
+    }
 
     private var receivedFirstRecord = false
     private var hasSnapshotFinished = true
@@ -76,7 +79,6 @@ class DebeziumRecordIterator<T>(
         // keep trying until the publisher is closed or until the queue is empty. the latter case is
         // possible when the publisher has shutdown but the consumer has not yet processed all
         // messages it emitted.
-        LOGGER.info { "Starting CDC Process" }
         val instantBeforeSync = Instant.now()
         while (!MoreBooleans.isTruthy(publisherStatusSupplier.get()) || !queue.isEmpty()) {
             val next: ChangeEvent<String?, String?>?

airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/source/relationaldb/InitialLoadTimeoutUtil.kt

@@ -13,7 +13,7 @@ private val LOGGER = KotlinLogging.logger {}
 
 object InitialLoadTimeoutUtil {
 
-    val MIN_INITIAL_LOAD_TIMEOUT: Duration = Duration.ofHours(1)
+    val MIN_INITIAL_LOAD_TIMEOUT: Duration = Duration.ofHours(4)
     val MAX_INITIAL_LOAD_TIMEOUT: Duration = Duration.ofHours(24)
     val DEFAULT_INITIAL_LOAD_TIMEOUT: Duration = Duration.ofHours(8)