bulk-core-toolkit-extract-jdbc: simplify JdbcPartitionReader

Author: Marius Posta

airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/JdbcPartitionReader.kt

@@ -6,7 +6,6 @@ import com.fasterxml.jackson.databind.node.ObjectNode
 import io.airbyte.cdk.command.OpaqueStateValue
 import io.airbyte.cdk.output.OutputConsumer
 import io.airbyte.cdk.util.Jsons
-import io.airbyte.protocol.models.v0.AirbyteMessage
 import io.airbyte.protocol.models.v0.AirbyteRecordMessage
 import java.util.concurrent.atomic.AtomicBoolean
 import java.util.concurrent.atomic.AtomicLong
@@ -48,15 +47,10 @@ sealed class JdbcPartitionReader<P : JdbcPartition<*>>(
     private val outData: ObjectNode = Jsons.objectNode()
 
     private val msg =
-        AirbyteMessage()
-            .withType(AirbyteMessage.Type.RECORD)
-            .withRecord(
-                AirbyteRecordMessage()
-                    .withEmittedAt(outputConsumer.emittedAt.toEpochMilli())
-                    .withStream(stream.name)
-                    .withNamespace(stream.namespace)
-                    .withData(outData)
-            )
+        AirbyteRecordMessage()
+            .withStream(stream.name)
+            .withNamespace(stream.namespace)
+            .withData(outData)
 
     val streamFieldNames: List<String> = stream.fields.map { it.id }