diff --git a/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/CdcPartitionReader.kt b/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/CdcPartitionReader.kt index c685d86c8cf8..20ce48d75b15 100644 --- a/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/CdcPartitionReader.kt +++ b/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/CdcPartitionReader.kt @@ -125,7 +125,6 @@ class CdcPartitionReader>( override fun accept(event: ChangeEvent) { numEvents.incrementAndGet() - println("dbz event: $event") // Get SourceRecord object if possible. // This object is the preferred way to obtain the current position. val sourceRecord: SourceRecord? =