2024-05-17 09:23:54.848 [WARN ] [main] [io.debezium.engine.DebeziumEngine$Builder] - More than one Debezium engine builder implementation was found, using class io.debezium.embedded.ConvertingEngineBuilderFactory (in Debezium 2.6 you can ignore this warning) 2024-05-17 09:23:55.076 [INFO ] [main] [io.debezium.embedded.EmbeddedWorkerConfig] - EmbeddedWorkerConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 10000 offset.flush.timeout.ms = 30000 offset.storage.file.filename = offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.discovery = hybrid_warn plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2024-05-17 09:23:55.161 [INFO ] [cdc-main-thread] [io.debezium.config.CommonConnectorConfig] - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2024-05-17 09:23:55.287 [DEBUG] [cdc-main-thread] [io.debezium.jdbc.JdbcConnection] - Connected to jdbc:postgresql://192.168.106.2:33216/postgresTest with {password=***, ApplicationName=Debezium Validate Connection, assumeMinServerVersion=9.4, user=test} 2024-05-17 09:23:55.298 [INFO ] [cdc-main-thread] [io.debezium.connector.postgresql.PostgresConnector] - Successfully tested connection for jdbc:postgresql://192.168.106.2:33216/postgresTest with user 'test' 2024-05-17 09:23:55.364 [INFO ] [pool-2-thread-1] [io.debezium.jdbc.JdbcConnection] - Connection gracefully closed 2024-05-17 09:23:55.396 [DEBUG] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Setting task state to 'INITIAL', previous state was 'INITIAL' 2024-05-17 09:23:55.399 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Starting PostgresConnectorTask with configuration: 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - connector.class = io.debezium.connector.postgresql.PostgresConnector 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - slot.name = myslot 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - publication.name = mypub 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - hstore.handling.mode = json 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - tombstones.on.delete = false 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - topic.prefix = debezium 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - binary.handling.mode = base64 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - offset.storage.file.filename = 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - flush.lsn.source = true 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - interval.handling.mode = string 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - errors.retry.delay.initial.ms = 300 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - value.converter = org.apache.kafka.connect.json.JsonConverter 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - key.converter = org.apache.kafka.connect.json.JsonConverter 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - publication.autocreate.mode = disabled 2024-05-17 09:23:55.402 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - database.user = test 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - database.dbname = postgresTest 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - offset.storage = io.customdz.DZOffsetStore 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - max.queue.size.in.bytes = 268435456 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - time.precision.mode = connect 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - offset.flush.timeout.ms = 30000 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - errors.retry.delay.max.ms = 10000 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - snapshot.max.threads = 4 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - column.include.list = public.alltypes.col_geography,public.alltypes.col_geometry,public.alltypes.col_smallserial,public.secondtable.col_pk 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - plugin.name = pgoutput 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - database.port = 33216 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - column.propagate.source.type = .* 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - offset.flush.interval.ms = 10000 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - include.unknown.datatypes = true 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - errors.max.retries = 0 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - database.hostname = 192.168.106.2 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - database.password = ******** 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - name = postgres-connector 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - table.include.list = public.alltypes,public.secondtable 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - snapshot.mode = initial_only 2024-05-17 09:23:55.403 [INFO ] [cdc-main-thread] [io.debezium.config.CommonConnectorConfig] - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2024-05-17 09:23:55.409 [INFO ] [cdc-main-thread] [io.debezium.config.CommonConnectorConfig] - Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy 2024-05-17 09:23:55.451 [DEBUG] [cdc-main-thread] [io.debezium.jdbc.JdbcConnection] - Connected to jdbc:postgresql://192.168.106.2:33216/postgresTest with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=test} 2024-05-17 09:23:55.453 [INFO ] [pool-3-thread-1] [io.debezium.jdbc.JdbcConnection] - Connection gracefully closed 2024-05-17 09:23:55.499 [DEBUG] [cdc-main-thread] [io.debezium.jdbc.JdbcConnection] - Connected to jdbc:postgresql://192.168.106.2:33216/postgresTest with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=test} 2024-05-17 09:23:55.768 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - No previous offsets found 2024-05-17 09:23:55.810 [DEBUG] [cdc-main-thread] [io.debezium.jdbc.JdbcConnection] - Connected to jdbc:postgresql://192.168.106.2:33216/postgresTest with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=test} 2024-05-17 09:23:56.106 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Connector started for the first time. 2024-05-17 09:23:56.153 [INFO ] [cdc-main-thread] [io.debezium.connector.postgresql.PostgresConnectorTask] - user 'test' connected to database 'postgresTest' on PostgreSQL 15.7 on x86_64-pc-linux-musl, compiled by gcc (Alpine 12.2.1_git20220924-r10) 12.2.1 20220924, 64-bit with roles: role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'test' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] 2024-05-17 09:23:56.175 [INFO ] [cdc-main-thread] [io.debezium.connector.postgresql.connection.PostgresConnection] - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/39FC8F0}, catalogXmin=755] 2024-05-17 09:23:56.179 [INFO ] [cdc-main-thread] [io.debezium.connector.postgresql.PostgresConnectorTask] - No previous offset found 2024-05-17 09:23:56.195 [INFO ] [cdc-main-thread] [io.debezium.util.Threads] - Requested thread factory for connector PostgresConnector, id = debezium named = SignalProcessor 2024-05-17 09:23:56.215 [INFO ] [cdc-main-thread] [io.debezium.util.Threads] - Requested thread factory for connector PostgresConnector, id = debezium named = change-event-source-coordinator 2024-05-17 09:23:56.215 [INFO ] [cdc-main-thread] [io.debezium.util.Threads] - Requested thread factory for connector PostgresConnector, id = debezium named = blocking-snapshot 2024-05-17 09:23:56.222 [INFO ] [cdc-main-thread] [io.debezium.util.Threads] - Creating thread debezium-postgresconnector-debezium-change-event-source-coordinator 2024-05-17 09:23:56.223 [DEBUG] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Setting task state to 'RUNNING', previous state was 'INITIAL' 2024-05-17 09:23:56.224 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:56.224 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:56.225 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:56.300 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Metrics registered 2024-05-17 09:23:56.301 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Context created 2024-05-17 09:23:56.306 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] - According to the connector configuration data will be snapshotted 2024-05-17 09:23:56.308 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 1 - Preparing 2024-05-17 09:23:56.383 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - 2 table(s) will be scanned 2024-05-17 09:23:56.384 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.alltypes 2024-05-17 09:23:56.481 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.secondtable 2024-05-17 09:23:56.565 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.alltypes' 2024-05-17 09:23:56.567 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.alltypes' to schemas under 'debezium.public.alltypes' 2024-05-17 09:23:56.573 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:56.577 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:56.578 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geography' (STRUCT) from column col_geography geography(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:56.579 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geometry' (STRUCT) from column col_geometry geometry(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:56.580 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:56.580 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}, {"name" : "col_geography", "index" : "1", "schema" : {"name" : "io.debezium.data.geometry.Geography", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geography", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}, {"name" : "col_geometry", "index" : "2", "schema" : {"name" : "io.debezium.data.geometry.Geometry", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geometry", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}]} 2024-05-17 09:23:56.587 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.secondtable' 2024-05-17 09:23:56.589 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.secondtable' to schemas under 'debezium.public.secondtable' 2024-05-17 09:23:56.589 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:56.589 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:56.589 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:56.589 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:56.590 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 2 - Determining captured tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.edges to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.addr to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table public.secondtable to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zip_state_loc to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.countysub_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.loader_variables to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.state_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.direction_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.loader_platform to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.state to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zip_lookup_all to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zip_state to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table public.alltypes to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.pagc_rules to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.tract to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.county to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.place to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.loader_lookuptables to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.county_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zip_lookup_base to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.cousub to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.featnames to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.pagc_lex to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.bg to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.pagc_gaz to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.secondary_unit_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.geocode_settings_default to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.street_type_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.geocode_settings to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.tabblock to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table topology.layer to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table topology.topology to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table public.city to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.place_lookup to the list of capture schema tables 2024-05-17 09:23:56.611 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.faces to the list of capture schema tables 2024-05-17 09:23:56.612 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zcta5 to the list of capture schema tables 2024-05-17 09:23:56.614 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.tabblock20 to the list of capture schema tables 2024-05-17 09:23:56.614 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.zip_lookup to the list of capture schema tables 2024-05-17 09:23:56.614 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Adding table tiger.addrfeat to the list of capture schema tables 2024-05-17 09:23:56.673 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Connected to jdbc:postgresql://192.168.106.2:33216/postgresTest with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=test} 2024-05-17 09:23:56.726 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - checking for more records... 2024-05-17 09:23:56.727 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine returned from polling task for records 2024-05-17 09:23:56.728 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received no records from the task 2024-05-17 09:23:56.728 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:56.728 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:56.728 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:56.877 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Created connection pool with 2 threads 2024-05-17 09:23:56.877 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 3 - Locking captured tables [public.alltypes, public.secondtable] 2024-05-17 09:23:56.892 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 4 - Determining snapshot offset 2024-05-17 09:23:56.896 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresOffsetContext] - Creating initial offset context 2024-05-17 09:23:56.909 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresOffsetContext] - Read xlogStart at 'LSN{0/39FE000}' from transaction '755' 2024-05-17 09:23:56.921 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] - Read xlogStart at 'LSN{0/39FE000}' from transaction '755' 2024-05-17 09:23:56.921 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 5 - Reading structure of captured tables 2024-05-17 09:23:56.922 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] - Reading structure of schema 'public' of catalog 'postgresTest' 2024-05-17 09:23:56.938 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - 2 table(s) will be scanned 2024-05-17 09:23:56.938 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.alltypes 2024-05-17 09:23:56.967 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.secondtable 2024-05-17 09:23:57.059 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - 2 table(s) will be scanned 2024-05-17 09:23:57.060 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.alltypes 2024-05-17 09:23:57.085 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.secondtable 2024-05-17 09:23:57.160 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.alltypes' 2024-05-17 09:23:57.160 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.alltypes' to schemas under 'debezium.public.alltypes' 2024-05-17 09:23:57.160 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geography' (STRUCT) from column col_geography geography(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geometry' (STRUCT) from column col_geometry geometry(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}, {"name" : "col_geography", "index" : "1", "schema" : {"name" : "io.debezium.data.geometry.Geography", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geography", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}, {"name" : "col_geometry", "index" : "2", "schema" : {"name" : "io.debezium.data.geometry.Geometry", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geometry", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}]} 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.secondtable' 2024-05-17 09:23:57.161 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.secondtable' to schemas under 'debezium.public.secondtable' 2024-05-17 09:23:57.162 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:57.162 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:57.162 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.162 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.162 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 6 - Persisting schema history 2024-05-17 09:23:57.162 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Snapshot step 7 - Snapshotting data 2024-05-17 09:23:57.163 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Creating snapshot worker pool with 2 worker thread(s) 2024-05-17 09:23:57.166 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - For table 'public.alltypes' using select statement: 'SELECT "col_smallserial", "col_geography", "col_geometry" FROM "public"."alltypes"' 2024-05-17 09:23:57.166 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalSnapshotChangeEventSource] - For table 'public.secondtable' using select statement: 'SELECT "col_pk" FROM "public"."secondtable"' 2024-05-17 09:23:57.174 [INFO ] [pool-4-thread-2] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Exporting data from table 'public.secondtable' (2 of 2 tables) 2024-05-17 09:23:57.174 [INFO ] [pool-4-thread-1] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Exporting data from table 'public.alltypes' (1 of 2 tables) 2024-05-17 09:23:57.233 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - checking for more records... 2024-05-17 09:23:57.234 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine returned from polling task for records 2024-05-17 09:23:57.234 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received no records from the task 2024-05-17 09:23:57.234 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:57.234 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:57.234 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:57.248 [INFO ] [pool-4-thread-2] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Finished exporting 1 records for table 'public.secondtable' (2 of 2 tables); total duration '00:00:00.074' 2024-05-17 09:23:57.293 [WARN ] [pool-4-thread-1] [io.debezium.connector.postgresql.PostgresValueConverter] - Error converting to a Geography type: col_geography geography(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.294 [WARN ] [pool-4-thread-1] [io.debezium.connector.postgresql.PostgresValueConverter] - Unexpected value for JDBC type 1111 and column col_geography geography(2147483647, 0) DEFAULT VALUE NULL: class=org.postgis.PGgeography 2024-05-17 09:23:57.295 [WARN ] [pool-4-thread-1] [io.debezium.connector.postgresql.PostgresValueConverter] - Error converting to a Geometry type: col_geometry geometry(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.295 [WARN ] [pool-4-thread-1] [io.debezium.connector.postgresql.PostgresValueConverter] - Unexpected value for JDBC type 1111 and column col_geometry geometry(2147483647, 0) DEFAULT VALUE NULL: class=org.postgis.PGgeometry 2024-05-17 09:23:57.297 [INFO ] [pool-4-thread-1] [io.debezium.relational.RelationalSnapshotChangeEventSource] - Finished exporting 1 records for table 'public.alltypes' (1 of 2 tables); total duration '00:00:00.123' 2024-05-17 09:23:57.300 [INFO ] [pool-5-thread-1] [io.debezium.jdbc.JdbcConnection] - Connection gracefully closed 2024-05-17 09:23:57.305 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] - Snapshot - Final stage 2024-05-17 09:23:57.305 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] - Snapshot completed 2024-05-17 09:23:57.306 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='debezium'db='postgresTest', lsn=LSN{0/39FE000}, txId=755, timestamp=2024-05-17T03:53:56.485385Z, snapshot=FALSE, schema=public, table=alltypes], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] 2024-05-17 09:23:57.341 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Snapshot result SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='debezium'db='postgresTest', lsn=LSN{0/39FE000}, txId=755, timestamp=2024-05-17T03:53:56.485385Z, snapshot=FALSE, schema=public, table=alltypes], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] 2024-05-17 09:23:57.346 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Connected metrics set to 'true' 2024-05-17 09:23:57.369 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - 2 table(s) will be scanned 2024-05-17 09:23:57.370 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.alltypes 2024-05-17 09:23:57.397 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.jdbc.JdbcConnection] - Retrieving columns of table public.secondtable 2024-05-17 09:23:57.469 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresSchema] - REPLICA IDENTITY for 'public.alltypes' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2024-05-17 09:23:57.474 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.connector.postgresql.PostgresSchema] - REPLICA IDENTITY for 'public.secondtable' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2024-05-17 09:23:57.474 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.alltypes' 2024-05-17 09:23:57.474 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.alltypes' to schemas under 'debezium.public.alltypes' 2024-05-17 09:23:57.475 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:57.476 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_smallserial' (INT16) from column col_smallserial smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('alltypes_col_smallserial_seq'::regclass) 2024-05-17 09:23:57.476 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geography' (STRUCT) from column col_geography geography(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.476 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_geometry' (STRUCT) from column col_geometry geometry(2147483647, 0) DEFAULT VALUE NULL 2024-05-17 09:23:57.484 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.485 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.alltypes' to schema: {"name" : "debezium.public.alltypes.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_smallserial", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}, {"name" : "col_geography", "index" : "1", "schema" : {"name" : "io.debezium.data.geometry.Geography", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geography", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}, {"name" : "col_geometry", "index" : "2", "schema" : {"name" : "io.debezium.data.geometry.Geometry", "type" : "STRUCT", "optional" : "true", "default" : null, "doc" : "Geometry", "version" : "1", "fields" : [{"name" : "wkb", "index" : "0", "schema" : {"type" : "BYTES", "optional" : "false", "default" : null}}, {"name" : "srid", "index" : "1", "schema" : {"type" : "INT32", "optional" : "true", "default" : null}}]}}]} 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.RelationalDatabaseSchema] - refreshing DB schema for table 'public.secondtable' 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapping table 'public.secondtable' to schemas under 'debezium.public.secondtable' 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - - field 'col_pk' (INT16) from column col_pk smallserial(5, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('secondtable_col_pk_seq'::regclass) 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped primary key for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.486 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.relational.TableSchemaBuilder] - Mapped columns for table 'public.secondtable' to schema: {"name" : "debezium.public.secondtable.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "col_pk", "index" : "0", "schema" : {"type" : "INT16", "optional" : "false", "default" : "0"}}]} 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'schema-changes' using class 'io.debezium.pipeline.signal.actions.SchemaChanges' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'snapshot-window-open' using class 'io.debezium.pipeline.signal.actions.snapshotting.OpenIncrementalSnapshotWindow' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'execute-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'snapshot-window-close' using class 'io.debezium.pipeline.signal.actions.snapshotting.CloseIncrementalSnapshotWindow' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'log' using class 'io.debezium.pipeline.signal.actions.Log' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'stop-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.StopSnapshot' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'resume-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.ResumeIncrementalSnapshot' 2024-05-17 09:23:57.500 [DEBUG] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - Registering signal 'pause-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.PauseIncrementalSnapshot' 2024-05-17 09:23:57.501 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.signal.SignalProcessor] - SignalProcessor started. Scheduling it every 5000ms 2024-05-17 09:23:57.501 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.util.Threads] - Creating thread debezium-postgresconnector-debezium-SignalProcessor 2024-05-17 09:23:57.501 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Streaming is disabled for snapshot mode initial_only 2024-05-17 09:23:57.501 [INFO ] [debezium-postgresconnector-debezium-change-event-source-coordinator] [io.debezium.pipeline.ChangeEventSourceCoordinator] - Connected metrics set to 'false' 2024-05-17 09:23:57.739 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - checking for more records... 2024-05-17 09:23:57.743 [DEBUG] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Sending 1 records to topic debezium.public.secondtable 2024-05-17 09:23:57.744 [DEBUG] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Sending 1 records to topic debezium.public.alltypes 2024-05-17 09:23:57.744 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine returned from polling task for records 2024-05-17 09:23:57.744 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received 2 records from the task 2024-05-17 09:23:57.747 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received 2 transformed records from the task 2024-05-17 09:23:57.824 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:57.824 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:57.824 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:58.330 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - checking for more records... 2024-05-17 09:23:58.331 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine returned from polling task for records 2024-05-17 09:23:58.331 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received no records from the task 2024-05-17 09:23:58.331 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:58.331 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:58.331 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:58.835 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - checking for more records... 2024-05-17 09:23:58.837 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine returned from polling task for records 2024-05-17 09:23:58.838 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Received no records from the task 2024-05-17 09:23:58.838 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine is polling task for records on thread Thread[cdc-main-thread,5,main] 2024-05-17 09:23:58.838 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - polling records... 2024-05-17 09:23:58.838 [DEBUG] [cdc-main-thread] [io.debezium.connector.base.ChangeEventQueue] - no records available or batch size not reached yet, sleeping a bit... 2024-05-17 09:23:59.099 [DEBUG] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Embedded engine interrupted on thread Thread[cdc-main-thread,5,main] while polling the task for records 2024-05-17 09:23:59.103 [INFO ] [cdc-main-thread] [io.debezium.embedded.EmbeddedEngine] - Stopping the task and engine 2024-05-17 09:23:59.103 [INFO ] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Stopping down connector 2024-05-17 09:23:59.106 [INFO ] [cdc-main-thread] [io.debezium.pipeline.signal.SignalProcessor] - SignalProcessor stopped 2024-05-17 09:23:59.107 [INFO ] [cdc-main-thread] [io.debezium.service.DefaultServiceRegistry] - Debezium ServiceRegistry stopped. 2024-05-17 09:23:59.108 [INFO ] [pool-6-thread-1] [io.debezium.jdbc.JdbcConnection] - Connection gracefully closed 2024-05-17 09:23:59.110 [INFO ] [pool-7-thread-1] [io.debezium.jdbc.JdbcConnection] - Connection gracefully closed 2024-05-17 09:23:59.110 [DEBUG] [cdc-main-thread] [io.debezium.connector.common.BaseSourceTask] - Setting task state to 'STOPPED', previous state was 'RUNNING' 2024-05-17 09:23:59.125 [INFO ] [main] [io.debezium.embedded.EmbeddedEngine] - Stopping the embedded engine