debezium log

debezium.log

connect            | [2021-09-29 12:19:47,148] INFO No previous offset has been found (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,148] INFO According to the connector configuration both schema and data will be snapshotted (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,149] INFO Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,149] INFO Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,256] INFO Snapshot step 3 - Locking captured tables [demo.dbo.ORDERS] (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,256] INFO Setting locking timeout to 10 s (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,260] INFO Executing schema locking (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,260] INFO Locking table demo.dbo.ORDERS (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,261] INFO Snapshot step 4 - Determining snapshot offset (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,268] INFO Snapshot step 5 - Reading structure of captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,268] INFO Reading structure of schema 'demo' (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,591] INFO Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,706] INFO Schema locks released. (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,706] INFO Snapshot step 7 - Snapshotting data (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,706] INFO Snapshotting contents of 1 tables while still in transaction (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,707] INFO 	 Exporting data from table 'demo.dbo.ORDERS' (1 of 1 tables) (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,708] INFO 	 For table 'demo.dbo.ORDERS' using select statement: 'SELECT [ORDERS].[pk_order_id],[ORDERS].[customer_id],[ORDERS].[order_ts],[ORDERS].[order_total_usd],[ORDERS].[item] FROM [dbo].[ORDERS]' (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,726] INFO 	 Finished exporting 8 records for table 'demo.dbo.ORDERS'; total duration '00:00:00.018' (io.debezium.relational.RelationalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,728] INFO Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,729] INFO Removing locking timeout (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,730] INFO Snapshot ended with SnapshotResult [status=COMPLETED, offset=SqlServerOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.sqlserver.Source:STRUCT}, sourceInfo=SourceInfo [serverName=dev, changeLsn=NULL, commitLsn=00000025:00000f58:0001, eventSerialNo=null, snapshot=FALSE, sourceTime=2021-09-29T12:19:47.725Z], partition={server=dev}, snapshotCompleted=true, eventSerialNo=1]] (io.debezium.pipeline.ChangeEventSourceCoordinator)
connect            | [2021-09-29 12:19:47,734] INFO Connected metrics set to 'true' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics)
connect            | [2021-09-29 12:19:47,734] INFO Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator)
connect            | [2021-09-29 12:19:47,735] INFO No incremental snapshot in progress, no action needed on start (io.debezium.pipeline.source.snapshot.incremental.SignalBasedIncrementalSnapshotChangeEventSource)
connect            | [2021-09-29 12:19:47,750] INFO Last position recorded in offsets is 00000025:00000f58:0001(NULL)[1] (io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource)
connect            | [2021-09-29 12:19:48,478] INFO The task will send records to topic 'dev.dbo.ORDERS' for the first time. Checking whether topic exists (org.apache.kafka.connect.runtime.WorkerSourceTask)
connect            | [2021-09-29 12:19:48,549] INFO Creating topic 'dev.dbo.ORDERS' (org.apache.kafka.connect.runtime.WorkerSourceTask)
connect            | [2021-09-29 12:19:48,677] INFO Created topic (name=dev.dbo.ORDERS, numPartitions=10, replicationFactor=2, replicasAssignments=null, configs={}) on brokers at b-1.dev-msk.o64p78.c1.kafka.eu-central-1.amazonaws.com:9096,b-2.dev-msk.o64p78.c1.kafka.eu-central-1.amazonaws.com:9096 (org.apache.kafka.connect.util.TopicAdmin)
connect            | [2021-09-29 12:19:48,677] INFO Created topic '(name=dev.dbo.ORDERS, numPartitions=10, replicationFactor=2, replicasAssignments=null, confi