docker-compose logs -f | grep io.debezium debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,676 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:22,677 INFO || Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:23,203 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:23,433 INFO || Added plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:24,536 INFO || Added plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:24,718 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:24,969 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:24,969 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:25,164 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,533 INFO || Added aliases 'Db2Connector' and 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,533 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,533 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,534 INFO || Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,534 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,534 INFO || Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,534 INFO || Added aliases 'VitessConnector' and 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,536 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,536 INFO || Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,537 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,539 INFO || Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,540 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,540 INFO || Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,540 INFO || Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:26,541 INFO || Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:39,593 DEBUG || Getting plugin class loader: 'PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}' for connector: io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | 2021-04-01 16:37:39,594 INFO || Creating connector shipment-order-connector-qa of type io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] debezium-connect | 2021-04-01 16:37:39,596 DEBUG || Getting plugin class loader: 'PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}' for connector: io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | 2021-04-01 16:37:39,649 INFO || Instantiated connector shipment-order-connector-qa with version 1.4.0.Final of type class io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] debezium-connect | task.class = class io.debezium.connector.postgresql.PostgresConnectorTask debezium-connect | 2021-04-01 16:37:39,670 INFO || Instantiated task shipment-order-connector-qa-0 with version 1.4.0.Final of type io.debezium.connector.postgresql.PostgresConnectorTask [org.apache.kafka.connect.runtime.Worker] debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,042 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "schema.whitelist" is deprecated and will be removed in future versions. Please use "schema.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "schema.blacklist" is deprecated and will be removed in future versions. Please use "schema.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "schema.whitelist" is deprecated and will be removed in future versions. Please use "schema.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 WARN || Using configuration property "schema.blacklist" is deprecated and will be removed in future versions. Please use "schema.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,049 INFO || Starting PostgresConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,051 INFO || connector.class = io.debezium.connector.postgresql.PostgresConnector [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,051 INFO || slot.name = shipment_order [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,051 INFO || tasks.max = 1 [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,051 INFO || transforms.replaceField.blacklist = id [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms = replaceField,routeRecords,SetSchemaMetadata [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.routeRecords.regex = (.*) [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.routeRecords.type = org.apache.kafka.connect.transforms.RegexRouter [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || table.whitelist = esprinter_data.shipment_order,esprinter_data.shipment_order_volume_ext,esprinter_data.shipment_order_volume_state_history_ext [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.sslmode = require [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.tcpKeepAlive = true [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.user = master [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.dbname = esprinter [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.replaceField.type = org.apache.kafka.connect.transforms.ReplaceField$Key [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.SetSchemaMetadata.type = org.apache.kafka.connect.transforms.SetSchemaMetadata$Key [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.SetSchemaMetadata.schema.version = 2 [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.server.name = shipment_order [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.port = 5432 [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || plugin.name = wal2json [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.SetSchemaMetadata.schema.name = shipment_order.esprinter_data.shipment_order.Key [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || schema.whitelist = esprinter_data [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || task.class = io.debezium.connector.postgresql.PostgresConnectorTask [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.hostname = db.spr.qa.intelipost.com.br [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || name = shipment-order-connector-qa [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || snapshot.mode = never [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,052 INFO || transforms.routeRecords.replacement = debezium.esprinter_data.shipment_order_all [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:37:40,059 WARN || Using configuration property "schema.whitelist" is deprecated and will be removed in future versions. Please use "schema.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,061 WARN || Using configuration property "schema.blacklist" is deprecated and will be removed in future versions. Please use "schema.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,062 WARN || Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,063 WARN || Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,064 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:37:40,305 DEBUG || Connected to jdbc:postgresql://db.spr.qa.intelipost.com.br:5432/esprinter with {sslmode=require, server.name=shipment_order, tcpKeepAlive=true, password=***, assumeMinServerVersion=9.4, user=master} [io.debezium.jdbc.JdbcConnection] debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connect | 2021-04-01 16:38:09,808 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:38:39,809 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:39:09,809 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:39:39,810 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:40:09,810 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:40:39,811 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:41:09,811 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:41:39,812 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:42:09,812 WARN || Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart [io.debezium.connector.common.BaseSourceTask] debezium-connect | 2021-04-01 16:42:18,366 WARN || Using configuration property "schema.blacklist" is deprecated and will be removed in future versions. Please use "schema.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,366 WARN || Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,366 WARN || Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,368 WARN || Using configuration property "schema.whitelist" is deprecated and will be removed in future versions. Please use "schema.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,368 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,368 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,370 WARN || Using configuration property "schema.blacklist" is deprecated and will be removed in future versions. Please use "schema.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,370 WARN || Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,370 WARN || Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,371 WARN || Using configuration property "schema.whitelist" is deprecated and will be removed in future versions. Please use "schema.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,371 WARN || Using configuration property "column.whitelist" is deprecated and will be removed in future versions. Please use "column.include.list" instead. [io.debezium.config.Configuration] debezium-connect | 2021-04-01 16:42:18,371 WARN || Using configuration property "column.blacklist" is deprecated and will be removed in future versions. Please use "column.exclude.list" instead. [io.debezium.config.Configuration] debezium-connect | role 'master' [superuser: false, replication: false, inherit: true, create role: true, create db: true, can log in: true] [io.debezium.connector.postgresql.PostgresConnectorTask] debezium-connect | 2021-04-01 16:42:18,914 INFO Postgres|shipment_order|postgres-connector-task Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{CC7/95052808}, catalogXmin=106315418] [io.debezium.connector.postgresql.connection.PostgresConnection] debezium-connect | 2021-04-01 16:42:18,915 INFO Postgres|shipment_order|postgres-connector-task No previous offset found [io.debezium.connector.postgresql.PostgresConnectorTask] debezium-connect | 2021-04-01 16:42:18,915 INFO Postgres|shipment_order|postgres-connector-task Snapshots are not allowed as per configuration, starting streaming logical changes only [io.debezium.connector.postgresql.snapshot.NeverSnapshotter] debezium-connect | 2021-04-01 16:42:18,933 INFO Postgres|shipment_order|postgres-connector-task Requested thread factory for connector PostgresConnector, id = shipment_order named = change-event-source-coordinator [io.debezium.util.Threads] debezium-connect | 2021-04-01 16:42:18,936 INFO Postgres|shipment_order|postgres-connector-task Creating thread debezium-postgresconnector-shipment_order-change-event-source-coordinator [io.debezium.util.Threads] debezium-connect | 2021-04-01 16:42:18,937 DEBUG Postgres|shipment_order|postgres-connector-task polling records... [io.debezium.connector.base.ChangeEventQueue] debezium-connect | 2021-04-01 16:42:18,938 DEBUG Postgres|shipment_order|postgres-connector-task no records available yet, sleeping a bit... [io.debezium.connector.base.ChangeEventQueue] debezium-connect | 2021-04-01 16:42:18,941 INFO Postgres|shipment_order|postgres-connector-task Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connect | 2021-04-01 16:42:18,941 INFO Postgres|shipment_order|postgres-connector-task Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connect | 2021-04-01 16:42:18,945 INFO Postgres|shipment_order|postgres-connector-task According to the connector configuration no snapshot will be executed [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connect | 2021-04-01 16:42:18,945 DEBUG Postgres|shipment_order|postgres-connector-task Skipping snapshotting [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] debezium-connect | 2021-04-01 16:42:18,946 INFO Postgres|shipment_order|postgres-connector-task Snapshot ended with SnapshotResult [status=SKIPPED, offset=null] [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connect | 2021-04-01 16:42:18,947 INFO Postgres|shipment_order|postgres-connector-task Creating initial offset context [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connect | 2021-04-01 16:42:18,952 INFO Postgres|shipment_order|postgres-connector-task Read xlogStart at 'LSN{CC7/97041068}' from transaction '106316148' [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connect | 2021-04-01 16:42:18,954 INFO Postgres|shipment_order|postgres-connector-task Connected metrics set to 'true' [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics] debezium-connect | 2021-04-01 16:42:18,954 INFO Postgres|shipment_order|postgres-connector-task Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connect | 2021-04-01 16:42:18,954 INFO Postgres|shipment_order|postgres-connector-task No previous LSN found in Kafka, streaming from the latest xlogpos or flushed LSN... [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource] debezium-connect | 2021-04-01 16:42:18,955 INFO Postgres|shipment_order|postgres-connector-task WAL position will not be searched [io.debezium.connector.postgresql.connection.WalPositionLocator]