2025-02-21T09:57:58.876Z INFO 2916385 --- [ Test worker] o.a.k.connect.json.JsonConverterConfig : JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2025-02-21T09:57:58.879Z INFO 2916385 --- [ Test worker] o.a.k.connect.json.JsonConverterConfig : JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2025-02-21T09:57:58.957Z INFO 2916385 --- [ Test worker] i.d.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 = 60000 offset.flush.timeout.ms = 5000 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 2025-02-21T09:57:58.963Z INFO 2916385 --- [ Test worker] c.w.p.p.service.debezium.DebeziumRunner : Started Debezium engine 2025-02-21T09:57:59.056Z INFO 2916385 --- [pool-2-thread-1] i.debezium.config.CommonConnectorConfig : Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-02-21T09:57:59.577Z INFO 2916385 --- [pool-2-thread-1] i.d.c.postgresql.PostgresConnector : Successfully tested connection for jdbc:postgresql://localhost:1116/postgres with user 'dbzuser' 2025-02-21T09:57:59.803Z INFO 2916385 --- [pool-3-thread-1] io.debezium.jdbc.JdbcConnection : Connection gracefully closed 2025-02-21T09:57:59.818Z INFO 2916385 --- [pool-2-thread-1] i.d.storage.jdbc.JdbcCommonConfig : Configuration for 'JdbcOffsetBackingStoreConfig' with prefix 'offset.storage.': {jdbc.password=********, jdbc.user=test, jdbc.url=jdbc:postgresql://localhost:1117/test, file.filename=} 2025-02-21T09:58:00.197Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Starting... 2025-02-21T09:58:00.227Z INFO 2916385 --- [pool-2-thread-1] i.d.s.j.offset.JdbcOffsetBackingStore : Starting JdbcOffsetBackingStore db 'jdbc:postgresql://localhost:1117/test' 2025-02-21T09:58:00.262Z INFO 2916385 --- [pool-2-thread-1] i.debezium.config.CommonConnectorConfig : Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-02-21T09:58:00.266Z INFO 2916385 --- [pool-2-thread-1] i.debezium.config.CommonConnectorConfig : Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy 2025-02-21T09:58:00.369Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.pool.HikariPool : HikariPool-1 - Added connection org.postgresql.jdbc.PgConnection@4257163f 2025-02-21T09:58:00.372Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Start completed. 2025-02-21T09:58:00.384Z INFO 2916385 --- [pool-4-thread-1] io.debezium.jdbc.JdbcConnection : Connection gracefully closed 2025-02-21T09:58:00.586Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13526, name:_pg_user_mappings] is already mapped 2025-02-21T09:58:00.600Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:18656, name:cxvaluecontainer] is already mapped 2025-02-21T09:58:00.602Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:19504, name:ebrbasicoperation] is already mapped 2025-02-21T09:58:00.628Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13200, name:cardinal_number] is already mapped 2025-02-21T09:58:00.629Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13203, name:character_data] is already mapped 2025-02-21T09:58:00.629Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13205, name:sql_identifier] is already mapped 2025-02-21T09:58:00.629Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13211, name:time_stamp] is already mapped 2025-02-21T09:58:00.629Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13213, name:yes_or_no] is already mapped 2025-02-21T09:58:00.650Z INFO 2916385 --- [ Test worker] o.s.b.a.e.web.EndpointLinksResolver : Exposing 1 endpoint beneath base path '' 2025-02-21T09:58:00.774Z INFO 2916385 --- [ Test worker] c.w.p.p.s.streaming.NoDefaultValuesIT : Started NoDefaultValuesIT in 5.936 seconds (process running for 33.991) 2025-02-21T09:58:00.791Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.HikariDataSource : HikariPool-2 - Starting... 2025-02-21T09:58:00.792Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13526, name:_pg_user_mappings] is already mapped 2025-02-21T09:58:00.812Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:18656, name:cxvaluecontainer] is already mapped 2025-02-21T09:58:00.820Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:19504, name:ebrbasicoperation] is already mapped 2025-02-21T09:58:00.830Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13200, name:cardinal_number] is already mapped 2025-02-21T09:58:00.831Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13203, name:character_data] is already mapped 2025-02-21T09:58:00.831Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13205, name:sql_identifier] is already mapped 2025-02-21T09:58:00.831Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13211, name:time_stamp] is already mapped 2025-02-21T09:58:00.831Z WARN 2916385 --- [pool-2-thread-1] i.d.connector.postgresql.TypeRegistry : Type [oid:13213, name:yes_or_no] is already mapped 2025-02-21T09:58:00.844Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.pool.HikariPool : HikariPool-2 - Added connection org.postgresql.jdbc.PgConnection@f9919a2 2025-02-21T09:58:00.847Z INFO 2916385 --- [ Test worker] com.zaxxer.hikari.HikariDataSource : HikariPool-2 - Start completed. 2025-02-21T09:58:00.864Z INFO 2916385 --- [pool-2-thread-1] i.d.c.postgresql.PostgresConnectorTask : No previous offset found 2025-02-21T09:58:00.874Z INFO 2916385 --- [pool-2-thread-1] i.d.c.postgresql.PostgresConnectorTask : user 'dbzuser' connected to database 'postgres' on PostgreSQL 15.3 (Debian 15.3-1.pgdg110+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 10.2.1-6) 10.2.1 20210110, 64-bit with roles: role 'pasx_and_debezium_group' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'dbzuser' [superuser: false, replication: true, inherit: true, create role: false, create db: false, can log in: true] 2025-02-21T09:58:00.881Z INFO 2916385 --- [pool-2-thread-1] i.d.c.p.connection.PostgresConnection : Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/ABB1340}, catalogXmin=20261] 2025-02-21T09:58:00.901Z INFO 2916385 --- [pool-2-thread-1] io.debezium.util.Threads : Requested thread factory for component PostgresConnector, id = postgres-mes-source named = SignalProcessor 2025-02-21T09:58:00.929Z INFO 2916385 --- [pool-2-thread-1] io.debezium.util.Threads : Requested thread factory for component PostgresConnector, id = postgres-mes-source named = change-event-source-coordinator 2025-02-21T09:58:00.930Z INFO 2916385 --- [pool-2-thread-1] io.debezium.util.Threads : Requested thread factory for component PostgresConnector, id = postgres-mes-source named = blocking-snapshot 2025-02-21T09:58:00.939Z INFO 2916385 --- [pool-2-thread-1] io.debezium.util.Threads : Creating thread debezium-postgresconnector-postgres-mes-source-change-event-source-coordinator 2025-02-21T09:58:00.941Z INFO 2916385 --- [pool-2-thread-1] c.w.p.p.s.d.DebeziumHealthIndicator : Debezium engine is healthy 2025-02-21T09:58:00.946Z INFO 2916385 --- [rce-coordinator] i.d.p.ChangeEventSourceCoordinator : Metrics registered 2025-02-21T09:58:00.947Z INFO 2916385 --- [rce-coordinator] i.d.p.ChangeEventSourceCoordinator : Context created 2025-02-21T09:58:00.954Z INFO 2916385 --- [rce-coordinator] .d.c.p.PostgresSnapshotChangeEventSource : According to the connector configuration data will be snapshotted 2025-02-21T09:58:00.959Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 1 - Preparing 2025-02-21T09:58:01.044Z INFO 2916385 --- [ Test worker] c.w.p.p.t.database.DebeziumDbSetup : Debezium setup took PT0.251578729S Mockito is currently self-attaching to enable the inline-mock-maker. This will no longer work in future releases of the JDK. Please add Mockito as an agent to your build what is described in Mockito's documentation: https://javadoc.io/doc/org.mockito/mockito-core/latest/org/mockito/Mockito.html#0.3 2025-02-21T09:58:01.214Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 2 - Determining captured tables 2025-02-21T09:58:01.229Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Adding table postgres.fat333manual.batchrecordreport to the list of capture schema tables 2025-02-21T09:58:01.234Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Adding table postgres.dbzuser.debezium_signals to the list of capture schema tables 2025-02-21T09:58:01.245Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Created connection pool with 1 threads 2025-02-21T09:58:01.245Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 3 - Locking captured tables [postgres.fat333manual.batchrecordreport, postgres.dbzuser.debezium_signals] 2025-02-21T09:58:01.250Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 4 - Determining snapshot offset 2025-02-21T09:58:01.252Z INFO 2916385 --- [rce-coordinator] i.d.c.postgresql.PostgresOffsetContext : Creating initial offset context 2025-02-21T09:58:01.257Z INFO 2916385 --- [rce-coordinator] i.d.c.postgresql.PostgresOffsetContext : Read xlogStart at 'LSN{0/B353718}' from transaction '20549' 2025-02-21T09:58:01.262Z INFO 2916385 --- [rce-coordinator] .d.c.p.PostgresSnapshotChangeEventSource : Read xlogStart at 'LSN{0/B353718}' from transaction '20549' 2025-02-21T09:58:01.263Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 5 - Reading structure of captured tables 2025-02-21T09:58:01.264Z INFO 2916385 --- [rce-coordinator] .d.c.p.PostgresSnapshotChangeEventSource : Reading structure of schema 'fat333manual' of catalog 'postgres' 2025-02-21T09:58:01.300Z INFO 2916385 --- [rce-coordinator] .d.c.p.PostgresSnapshotChangeEventSource : Reading structure of schema 'dbzuser' of catalog 'postgres' 2025-02-21T09:58:01.369Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 6 - Persisting schema history 2025-02-21T09:58:01.370Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Snapshot step 7 - Snapshotting data 2025-02-21T09:58:01.371Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : Creating snapshot worker pool with 1 worker thread(s) 2025-02-21T09:58:01.380Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : For table 'postgres.fat333manual.batchrecordreport' using select statement: 'SELECT "entitykey", "jcoffeeoptimisticconcurrency", "releasesignaturecollectiontype", "version", "actualquantity", "archivedate", "changecomment", "currentstatus", "customid", "equipment", "equipmenttype", "erprelevant", "extensionaspect1", "extensionaspect10", "extensionaspect2", "extensionaspect3", "extensionaspect4", "extensionaspect5", "extensionaspect6", "extensionaspect7", "extensionaspect8", "extensionaspect9", "mbrfulfilledoption", "mbrlogicalinstanceid", "originkey", "reviewcppstatus", "reviewcqastatus", "reviewexceptionstatus", "specificationtype", "storageunit", "v2manufacturingorderid", "manufacturingorderheadid", "archivestatus" FROM "postgres"."fat333manual"."batchrecordreport"' 2025-02-21T09:58:01.401Z INFO 2916385 --- [rce-coordinator] .d.r.RelationalSnapshotChangeEventSource : For table 'postgres.dbzuser.debezium_signals' using select statement: 'SELECT "id", "type", "data" FROM "postgres"."dbzuser"."debezium_signals"' 2025-02-21T09:58:01.415Z INFO 2916385 --- [pool-5-thread-1] .d.r.RelationalSnapshotChangeEventSource : Exporting data from table 'postgres.fat333manual.batchrecordreport' (1 of 2 tables) 2025-02-21T09:58:01.449Z INFO 2916385 --- [pool-5-thread-1] .d.r.RelationalSnapshotChangeEventSource : Finished exporting 0 records for table 'postgres.fat333manual.batchrecordreport' (1 of 2 tables); total duration '00:00:00.034' 2025-02-21T09:58:01.452Z INFO 2916385 --- [pool-5-thread-1] .d.r.RelationalSnapshotChangeEventSource : Exporting data from table 'postgres.dbzuser.debezium_signals' (2 of 2 tables) 2025-02-21T09:58:01.462Z INFO 2916385 --- [pool-5-thread-1] .d.r.RelationalSnapshotChangeEventSource : Finished exporting 0 records for table 'postgres.dbzuser.debezium_signals' (2 of 2 tables); total duration '00:00:00.01' 2025-02-21T09:58:01.471Z INFO 2916385 --- [rce-coordinator] .d.p.s.AbstractSnapshotChangeEventSource : Snapshot - Final stage 2025-02-21T09:58:01.471Z INFO 2916385 --- [rce-coordinator] .d.p.s.AbstractSnapshotChangeEventSource : Snapshot completed 2025-02-21T09:58:01.471Z INFO 2916385 --- [rce-coordinator] i.d.p.ChangeEventSourceCoordinator : Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='postgres-mes-source'db='postgres', lsn=LSN{0/B353718}, txId=20549, timestamp=2025-02-21T09:58:01.263Z, 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-02-21T09:58:01.487Z INFO 2916385 --- [rce-coordinator] i.d.p.ChangeEventSourceCoordinator : Connected metrics set to 'true' 2025-02-21T09:58:01.568Z INFO 2916385 --- [rce-coordinator] i.d.connector.postgresql.PostgresSchema : REPLICA IDENTITY for 'postgres.fat333manual.batchrecordreport' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-02-21T09:58:01.570Z INFO 2916385 --- [rce-coordinator] i.d.connector.postgresql.PostgresSchema : REPLICA IDENTITY for 'postgres.dbzuser.debezium_signals' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2025-02-21T09:58:01.581Z INFO 2916385 --- [rce-coordinator] ractIncrementalSnapshotChangeEventSource : No incremental snapshot in progress, no action needed on start 2025-02-21T09:58:01.588Z INFO 2916385 --- [rce-coordinator] i.d.pipeline.signal.SignalProcessor : SignalProcessor started. Scheduling it every 5000ms 2025-02-21T09:58:01.589Z INFO 2916385 --- [rce-coordinator] io.debezium.util.Threads : Creating thread debezium-postgresconnector-postgres-mes-source-SignalProcessor 2025-02-21T09:58:01.590Z INFO 2916385 --- [rce-coordinator] i.d.p.ChangeEventSourceCoordinator : Starting streaming 2025-02-21T09:58:01.590Z INFO 2916385 --- [rce-coordinator] d.c.p.PostgresStreamingChangeEventSource : Retrieved latest position from stored offset 'LSN{0/B353718}' 2025-02-21T09:58:01.591Z INFO 2916385 --- [rce-coordinator] i.d.c.p.connection.WalPositionLocator : Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{0/B353718}' 2025-02-21T09:58:01.591Z INFO 2916385 --- [rce-coordinator] i.d.c.p.c.PostgresReplicationConnection : Initializing PgOutput logical decoder publication 2025-02-21T09:58:01.656Z INFO 2916385 --- [rce-coordinator] i.d.c.p.connection.PostgresConnection : Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/ABB1340}, catalogXmin=20261] 2025-02-21T09:58:01.663Z INFO 2916385 --- [pool-6-thread-1] io.debezium.jdbc.JdbcConnection : Connection gracefully closed 2025-02-21T09:58:01.689Z INFO 2916385 --- [rce-coordinator] io.debezium.util.Threads : Requested thread factory for component PostgresConnector, id = postgres-mes-source named = keep-alive 2025-02-21T09:58:01.691Z INFO 2916385 --- [rce-coordinator] io.debezium.util.Threads : Creating thread debezium-postgresconnector-postgres-mes-source-keep-alive 2025-02-21T09:58:01.741Z INFO 2916385 --- [rce-coordinator] i.d.connector.postgresql.PostgresSchema : REPLICA IDENTITY for 'postgres.fat333manual.batchrecordreport' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-02-21T09:58:01.742Z INFO 2916385 --- [rce-coordinator] i.d.connector.postgresql.PostgresSchema : REPLICA IDENTITY for 'postgres.dbzuser.debezium_signals' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2025-02-21T09:58:01.745Z INFO 2916385 --- [rce-coordinator] d.c.p.PostgresStreamingChangeEventSource : Processing messages