C:\some\path\.jdks\corretto-17.0.7\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2025.2.1\lib\idea_rt.jar=60988" -Dfile.encoding=UTF-8 @C:\some\path\AppData\Local\Temp\idea_arg_file174621357 com.mycompany.replication.ReplicatorApp Standard Commons Logging discovery in action with spring-jcl: please remove commons-logging.jar from classpath in order to avoid potential conflicts Standard Commons Logging discovery in action with spring-jcl: please remove commons-logging.jar from classpath in order to avoid potential conflicts 2025-09-15 17:17:58,813 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - Starting JdbcSinkConnectorConfig with configuration: 2025-09-15 17:17:58,818 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connector.class = io.debezium.connector.jdbc.JdbcSinkConnector 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.password = ******** 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - primary.key.mode = record_key 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - converter.type = header 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - tasks.max = 1 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - topics = some.topic 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.username = *** 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - internal.key.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - collection.name.format = ${source.schema}.${source.table} 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-some.name.dat 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - delete.enabled = true 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - internal.value.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - name = some.name 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - auto.create = true 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - value.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.url = jdbc:postgresql://localhost:5432/replication 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - insert.mode = upsert 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - key.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:58,819 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - schemas.enable = true 2025-09-15 17:17:59,039 INFO [main] io.debezium.connector.jdbc.dialect.DatabaseDialectResolver - Using dialect io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect 2025-09-15 17:18:00,662 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 = 0 offset.flush.timeout.ms = 5000 offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-lrx_sc_tobjectstorage_tlinkstorage.dat 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 2025-09-15 17:18:00,689 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-09-15 17:18:00,742 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnector - Successfully tested connection for jdbc:postgresql://localhost:5432/my_db with user '***' 2025-09-15 17:18:00,750 INFO [pool-3-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:18:00,786 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - Starting PostgresConnectorTask with configuration: connector.class = io.debezium.connector.postgresql.PostgresConnector slot.name = rs_lrx_sc_tobjectstorage_tlinkstorage publication.name = pub_lrx_sc_tobjectstorage_tlinkstorage provide.transaction.metadata = true tombstones.on.delete = false topic.prefix = prefix_lrx_sc_tobjectstorage_tlinkstorage offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-lrx_sc_tobjectstorage_tlinkstorage.dat signal.data.collection = public.debezium_signal copy.existing = false errors.retry.delay.initial.ms = 300 value.converter = org.apache.kafka.connect.json.JsonConverter key.converter = org.apache.kafka.connect.json.JsonConverter publication.autocreate.mode = all_tables database.user = *** database.dbname = my_db offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore offset.flush.timeout.ms = 5000 errors.retry.delay.max.ms = 10000 database.port = 5432 plugin.name = pgoutput offset.flush.interval.ms = 0 snapshot.mode.custom.name = lrx-initial errors.max.retries = -1 database.hostname = localhost database.password = ******** name = lrx_sc_tobjectstorage_tlinkstorage table.include.list = public.tobjectstorage,public.tlinkstorage snapshot.mode = custom 2025-09-15 17:18:00,786 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-09-15 17:18:00,786 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy 2025-09-15 17:18:00,828 INFO [pool-4-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13523, name:_pg_user_mappings] is already mapped 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13197, name:cardinal_number] is already mapped 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13200, name:character_data] is already mapped 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13202, name:sql_identifier] is already mapped 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13208, name:time_stamp] is already mapped 2025-09-15 17:18:00,867 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13210, name:yes_or_no] is already mapped 2025-09-15 17:18:00,889 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - Found previous partition offset PostgresPartition [sourcePartition={server=prefix_lrx_sc_tobjectstorage_tlinkstorage}]: {lsn=217670462312, txId=13857952, ts_usec=1757945845849943} 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13523, name:_pg_user_mappings] is already mapped 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13197, name:cardinal_number] is already mapped 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13200, name:character_data] is already mapped 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13202, name:sql_identifier] is already mapped 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13208, name:time_stamp] is already mapped 2025-09-15 17:18:00,921 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13210, name:yes_or_no] is already mapped 2025-09-15 17:18:00,943 INFO [pool-2-thread-1] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{32/AE2E8448}, catalogXmin=13857956] 2025-09-15 17:18:00,945 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnectorTask - Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prefix_lrx_sc_tobjectstorage_tlinkstorage'db='my_db', lsn=LSN{32/AE2BAB68}, txId=13857952, timestamp=2025-09-15T14:17:25.849943Z, snapshot=FALSE, schema=, table=], 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]] 2025-09-15 17:18:00,953 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnectorTask - user '***' connected to database 'my_db' on PostgreSQL 15.2, compiled by Visual C++ build 1914, 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 'apacs' [superuser: true, replication: false, 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 'apc' [superuser: true, replication: false, inherit: true, create role: true, create db: true, can log in: true] 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] role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] role '***' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] 2025-09-15 17:18:00,953 INFO [pool-2-thread-1] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{32/AE2E8448}, catalogXmin=13857956] 2025-09-15 17:18:00,964 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = SignalProcessor 2025-09-15 17:18:00,975 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = change-event-source-coordinator 2025-09-15 17:18:00,975 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = blocking-snapshot 2025-09-15 17:18:00,979 INFO [pool-2-thread-1] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator 2025-09-15 17:18:00,980 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Metrics registered 2025-09-15 17:18:00,981 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Context created 2025-09-15 17:18:00,987 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - A previous offset indicating a completed snapshot has been found. 2025-09-15 17:18:00,987 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - According to the connector configuration no snapshot will be executed 2025-09-15 17:18:00,990 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prefix_lrx_sc_tobjectstorage_tlinkstorage'db='my_db', lsn=LSN{32/AE2BAB68}, txId=13857952, timestamp=2025-09-15T14:17:25.849943Z, snapshot=FALSE, schema=, table=], 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]]] 2025-09-15 17:18:00,993 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Connected metrics set to 'true' 2025-09-15 17:18:01,026 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.debezium_signal' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:18:01,027 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.tlinkstorage' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:18:01,028 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.tobjectstorage' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:18:01,083 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource - No incremental snapshot in progress, no action needed on start 2025-09-15 17:18:01,105 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor started. Scheduling it every 5000ms 2025-09-15 17:18:01,106 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-SignalProcessor 2025-09-15 17:18:01,107 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Starting streaming 2025-09-15 17:18:01,107 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Retrieved latest position from stored offset 'LSN{32/AE2BAB68}' 2025-09-15 17:18:01,110 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.WalPositionLocator - Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{32/AE2BAB68}' 2025-09-15 17:18:01,110 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Initializing PgOutput logical decoder publication 2025-09-15 17:18:01,172 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{32/AE2E8448}, catalogXmin=13857956] 2025-09-15 17:18:01,173 INFO [pool-5-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:18:01,225 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = keep-alive 2025-09-15 17:18:01,227 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-keep-alive 2025-09-15 17:18:01,228 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Processing messages 2025-09-15 17:18:19,704 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - 14 records sent during previous 00:00:18.932, last recorded offset of {server=prefix_lrx_sc_tobjectstorage_tlinkstorage} partition is {transaction_id=13858172, lsn_proc=217670834024, messageType=COMMIT, lsn_commit=217670834024, transaction_data_collection_order_public.tobjectstorage=1, lsn=217670834024, txId=13858172, ts_usec=1757945899262959}