2025-10-23T09:42:29.301238257Z 2025-10-23T09:42:29,301 INFO   ||  8 records sent during previous 00:00:40.582, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494016, messageType=COMMIT, lsn_commit=49928494016, lsn=49928494016, txId=260746, ts_usec=1761212483549192}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:42:29.959802202Z 2025-10-23T09:42:29,959 INFO   ||  Successfully processed removal of connector 'pg-connector'   [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
2025-10-23T09:42:29.959843564Z 2025-10-23T09:42:29,959 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Connector pg-connector config removed   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:29.960092893Z 2025-10-23T09:42:29,959 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:29.960154065Z 2025-10-23T09:42:29,960 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:29.961356646Z 2025-10-23T09:42:29,961 INFO   ||  172.17.0.1 - - [23/Oct/2025:09:42:29 +0000] "DELETE /connectors/pg-connector HTTP/1.1" 204 0 "" "curl/8.11.1" 11   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T09:42:29.962769242Z 2025-10-23T09:42:29,962 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=10, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:29.965393431Z 2025-10-23T09:42:29,965 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=10, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:29.965666876Z 2025-10-23T09:42:29,965 INFO   ||  Stopping connector pg-connector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:29.965732512Z 2025-10-23T09:42:29,965 INFO   ||  Scheduled shutdown for WorkerConnector{id=pg-connector}   [org.apache.kafka.connect.runtime.WorkerConnector]
2025-10-23T09:42:29.965810294Z 2025-10-23T09:42:29,965 INFO   ||  Stopping task pg-connector-0   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:29.966067816Z 2025-10-23T09:42:29,966 INFO   ||  Completed shutdown for WorkerConnector{id=pg-connector}   [org.apache.kafka.connect.runtime.WorkerConnector]
2025-10-23T09:42:30.303243569Z 2025-10-23T09:42:30,303 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 4 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:42:30.311260163Z 2025-10-23T09:42:30,311 INFO   ||  Stopping down connector   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:42:30.591143502Z 2025-10-23T09:42:30,591 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.591187551Z 2025-10-23T09:42:30,591 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.591424243Z 2025-10-23T09:42:30,591 ERROR  ||  Unexpected exception while performing keepalive status update on the replication stream   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T09:42:30.591439403Z java.lang.InterruptedException: sleep interrupted
2025-10-23T09:42:30.591442157Z 	at java.base/java.lang.Thread.sleep0(Native Method) ~[?:?]
2025-10-23T09:42:30.591444298Z 	at java.base/java.lang.Thread.sleep(Thread.java:509) [?:?]
2025-10-23T09:42:30.591446062Z 	at io.debezium.util.Metronome$1.pause(Metronome.java:57) ~[debezium-core-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:42:30.591447887Z 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:1007) ~[debezium-connector-postgres-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:42:30.591449884Z 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
2025-10-23T09:42:30.591451637Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
2025-10-23T09:42:30.591453283Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
2025-10-23T09:42:30.591467896Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
2025-10-23T09:42:30.591471146Z 	at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
2025-10-23T09:42:30.591689135Z 2025-10-23T09:42:30,591 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:30.591806185Z 2025-10-23T09:42:30,591 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.591864739Z 2025-10-23T09:42:30,591 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.592295776Z 2025-10-23T09:42:30,592 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:30.592386902Z 2025-10-23T09:42:30,592 INFO   Postgres||streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:30.592481376Z 2025-10-23T09:42:30,592 INFO   Postgres||streaming  Connected metrics set to 'false'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:30.592638704Z 2025-10-23T09:42:30,592 INFO   ||  SignalProcessor stopped   [io.debezium.pipeline.signal.SignalProcessor]
2025-10-23T09:42:30.592700298Z 2025-10-23T09:42:30,592 INFO   ||  Debezium ServiceRegistry stopped.   [io.debezium.service.DefaultServiceRegistry]
2025-10-23T09:42:30.592803120Z 2025-10-23T09:42:30,592 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.592852422Z 2025-10-23T09:42:30,592 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:30.593269969Z 2025-10-23T09:42:30,593 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:30.593474879Z 2025-10-23T09:42:30,593 INFO   ||  [Producer clientId=connector-producer-pg-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2025-10-23T09:42:30.594844259Z 2025-10-23T09:42:30,594 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:42:30.594862601Z 2025-10-23T09:42:30,594 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:42:30.594865518Z 2025-10-23T09:42:30,594 INFO   ||  Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:42:30.594867826Z 2025-10-23T09:42:30,594 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:42:30.594972161Z 2025-10-23T09:42:30,594 INFO   ||  App info kafka.producer for connector-producer-pg-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T09:42:30.595716269Z 2025-10-23T09:42:30,595 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished stopping tasks in preparation for rebalance   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.597202846Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished flushing status backing store in preparation for rebalance   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.597298688Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 10 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=100, connectorIds=[], taskIds=[], revokedConnectorIds=[pg-connector], revokedTaskIds=[pg-connector-0], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.597609614Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 100   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.597619993Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.597630599Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:30.597644574Z 2025-10-23T09:42:30,597 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:30.598720572Z 2025-10-23T09:42:30,598 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=11, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:30.600013706Z 2025-10-23T09:42:30,599 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=11, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:30.600204073Z 2025-10-23T09:42:30,600 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 11 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=100, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.600475922Z 2025-10-23T09:42:30,600 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 100   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:30.600489692Z 2025-10-23T09:42:30,600 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.881304860Z 2025-10-23T09:42:38,881 INFO   ||  Validating connector io.debezium.connector.postgresql.PostgresConnector, version 3.3.1.Final   [org.apache.kafka.connect.runtime.AbstractHerder]
2025-10-23T09:42:38.882489982Z 2025-10-23T09:42:38,882 INFO   ||  AbstractConfig values: 
2025-10-23T09:42:38.882506249Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.883543100Z 2025-10-23T09:42:38,883 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2025-10-23T09:42:38.883892460Z 2025-10-23T09:42:38,883 INFO   ||  Requested thread factory for component PostgresConnector, id = pg-dev named = connection-validation   [io.debezium.util.Threads]
2025-10-23T09:42:38.883959085Z 2025-10-23T09:42:38,883 INFO   ||  Creating thread debezium-postgresconnector-pg-dev-connection-validation   [io.debezium.util.Threads]
2025-10-23T09:42:38.891573293Z 2025-10-23T09:42:38,891 INFO   ||  Successfully tested connection for jdbc:postgresql://postgres:5432/postgres with user 'postgres'   [io.debezium.connector.postgresql.PostgresConnector]
2025-10-23T09:42:38.894572897Z 2025-10-23T09:42:38,894 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:38.894589966Z 2025-10-23T09:42:38,894 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:38.895075394Z 2025-10-23T09:42:38,894 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:38.903689052Z 2025-10-23T09:42:38,903 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Connector pg-connector config updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.903837138Z 2025-10-23T09:42:38,903 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.903877941Z 2025-10-23T09:42:38,903 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.905022702Z 2025-10-23T09:42:38,904 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=12, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.905496593Z 2025-10-23T09:42:38,905 INFO   ||  172.17.0.1 - - [23/Oct/2025:09:42:38 +0000] "POST /connectors/ HTTP/1.1" 201 745 "" "curl/8.11.1" 26   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T09:42:38.908043439Z 2025-10-23T09:42:38,907 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=12, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.908247812Z 2025-10-23T09:42:38,908 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 12 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=101, connectorIds=[pg-connector], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.908415195Z 2025-10-23T09:42:38,908 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 101   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.908531640Z 2025-10-23T09:42:38,908 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connector pg-connector   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.908657799Z 2025-10-23T09:42:38,908 INFO   ||  Creating connector pg-connector of type io.debezium.connector.postgresql.PostgresConnector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.909187886Z 2025-10-23T09:42:38,909 INFO   ||  SourceConnectorConfig values: 
2025-10-23T09:42:38.909199132Z 	config.action.reload = restart
2025-10-23T09:42:38.909202257Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.909204420Z 	connector.plugin.version = null
2025-10-23T09:42:38.909206397Z 	errors.log.enable = false
2025-10-23T09:42:38.909208246Z 	errors.log.include.messages = false
2025-10-23T09:42:38.909210156Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.909211957Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.909213745Z 	errors.tolerance = none
2025-10-23T09:42:38.909215686Z 	exactly.once.support = requested
2025-10-23T09:42:38.909217481Z 	header.converter = null
2025-10-23T09:42:38.909219234Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.909221281Z 	key.converter = null
2025-10-23T09:42:38.909223114Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.909224903Z 	name = pg-connector
2025-10-23T09:42:38.909226663Z 	offsets.storage.topic = null
2025-10-23T09:42:38.909228498Z 	predicates = []
2025-10-23T09:42:38.909230299Z 	tasks.max = 1
2025-10-23T09:42:38.909232049Z 	tasks.max.enforce = true
2025-10-23T09:42:38.909233809Z 	topic.creation.groups = []
2025-10-23T09:42:38.909235588Z 	transaction.boundary = poll
2025-10-23T09:42:38.909237425Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.909239278Z 	transforms = []
2025-10-23T09:42:38.909241073Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.909242955Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.909244907Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.909454640Z 2025-10-23T09:42:38,909 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T09:42:38.909461714Z 	config.action.reload = restart
2025-10-23T09:42:38.909475185Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.909477708Z 	connector.plugin.version = null
2025-10-23T09:42:38.909479651Z 	errors.log.enable = false
2025-10-23T09:42:38.909481442Z 	errors.log.include.messages = false
2025-10-23T09:42:38.909483309Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.909485098Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.909487020Z 	errors.tolerance = none
2025-10-23T09:42:38.909489005Z 	exactly.once.support = requested
2025-10-23T09:42:38.909490880Z 	header.converter = null
2025-10-23T09:42:38.909492600Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.909494448Z 	key.converter = null
2025-10-23T09:42:38.909496185Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.909498226Z 	name = pg-connector
2025-10-23T09:42:38.909499962Z 	offsets.storage.topic = null
2025-10-23T09:42:38.909501711Z 	predicates = []
2025-10-23T09:42:38.909503505Z 	tasks.max = 1
2025-10-23T09:42:38.909505282Z 	tasks.max.enforce = true
2025-10-23T09:42:38.909506959Z 	topic.creation.groups = []
2025-10-23T09:42:38.909508646Z 	transaction.boundary = poll
2025-10-23T09:42:38.909510479Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.909512361Z 	transforms = []
2025-10-23T09:42:38.909514131Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.909515919Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.909517819Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.909856091Z 2025-10-23T09:42:38,909 INFO   ||  Instantiated connector pg-connector with version 3.3.1.Final of type class io.debezium.connector.postgresql.PostgresConnector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.909924008Z 2025-10-23T09:42:38,909 INFO   ||  Finished creating connector pg-connector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.910092708Z 2025-10-23T09:42:38,909 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.911295539Z 2025-10-23T09:42:38,911 INFO   ||  SourceConnectorConfig values: 
2025-10-23T09:42:38.911328115Z 	config.action.reload = restart
2025-10-23T09:42:38.911332420Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.911334857Z 	connector.plugin.version = null
2025-10-23T09:42:38.911336800Z 	errors.log.enable = false
2025-10-23T09:42:38.911339108Z 	errors.log.include.messages = false
2025-10-23T09:42:38.911341148Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.911362813Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.911365284Z 	errors.tolerance = none
2025-10-23T09:42:38.911367177Z 	exactly.once.support = requested
2025-10-23T09:42:38.911368963Z 	header.converter = null
2025-10-23T09:42:38.911370728Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.911372711Z 	key.converter = null
2025-10-23T09:42:38.911374488Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.911376315Z 	name = pg-connector
2025-10-23T09:42:38.911378046Z 	offsets.storage.topic = null
2025-10-23T09:42:38.911379828Z 	predicates = []
2025-10-23T09:42:38.911381655Z 	tasks.max = 1
2025-10-23T09:42:38.911383563Z 	tasks.max.enforce = true
2025-10-23T09:42:38.911385346Z 	topic.creation.groups = []
2025-10-23T09:42:38.911387081Z 	transaction.boundary = poll
2025-10-23T09:42:38.911388971Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.911390753Z 	transforms = []
2025-10-23T09:42:38.911392519Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.911394395Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.911396195Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.911728344Z 2025-10-23T09:42:38,911 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T09:42:38.911749035Z 	config.action.reload = restart
2025-10-23T09:42:38.911815307Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.911818862Z 	connector.plugin.version = null
2025-10-23T09:42:38.911821121Z 	errors.log.enable = false
2025-10-23T09:42:38.911826566Z 	errors.log.include.messages = false
2025-10-23T09:42:38.911829011Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.911831152Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.911833275Z 	errors.tolerance = none
2025-10-23T09:42:38.911835525Z 	exactly.once.support = requested
2025-10-23T09:42:38.911837766Z 	header.converter = null
2025-10-23T09:42:38.911839873Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.911842275Z 	key.converter = null
2025-10-23T09:42:38.911844578Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.911850311Z 	name = pg-connector
2025-10-23T09:42:38.911852754Z 	offsets.storage.topic = null
2025-10-23T09:42:38.911854832Z 	predicates = []
2025-10-23T09:42:38.911856827Z 	tasks.max = 1
2025-10-23T09:42:38.911858883Z 	tasks.max.enforce = true
2025-10-23T09:42:38.911870240Z 	topic.creation.groups = []
2025-10-23T09:42:38.911873066Z 	transaction.boundary = poll
2025-10-23T09:42:38.911875366Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.911877688Z 	transforms = []
2025-10-23T09:42:38.911879905Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.911882123Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.911884259Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.931768474Z 2025-10-23T09:42:38,931 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Tasks [pg-connector-0] configs updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.932961803Z 2025-10-23T09:42:38,932 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.932992898Z 2025-10-23T09:42:38,932 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.934167274Z 2025-10-23T09:42:38,934 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=13, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.936217283Z 2025-10-23T09:42:38,936 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=13, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:42:38.936451725Z 2025-10-23T09:42:38,936 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 13 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=103, connectorIds=[pg-connector], taskIds=[pg-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.936628854Z 2025-10-23T09:42:38,936 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 103   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.936868950Z 2025-10-23T09:42:38,936 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting task pg-connector-0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.937000958Z 2025-10-23T09:42:38,936 INFO   ||  Creating task pg-connector-0   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.937478267Z 2025-10-23T09:42:38,937 INFO   ||  ConnectorConfig values: 
2025-10-23T09:42:38.937492775Z 	config.action.reload = restart
2025-10-23T09:42:38.937496090Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.937498551Z 	connector.plugin.version = null
2025-10-23T09:42:38.937527034Z 	errors.log.enable = false
2025-10-23T09:42:38.937529754Z 	errors.log.include.messages = false
2025-10-23T09:42:38.937532147Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.937534165Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.937535975Z 	errors.tolerance = none
2025-10-23T09:42:38.937537834Z 	header.converter = null
2025-10-23T09:42:38.937539606Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.937541584Z 	key.converter = null
2025-10-23T09:42:38.937543391Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.937545183Z 	name = pg-connector
2025-10-23T09:42:38.937547071Z 	predicates = []
2025-10-23T09:42:38.937548859Z 	tasks.max = 1
2025-10-23T09:42:38.937550655Z 	tasks.max.enforce = true
2025-10-23T09:42:38.937552500Z 	transforms = []
2025-10-23T09:42:38.937554411Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.937556791Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.937558853Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.937627257Z 2025-10-23T09:42:38,937 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T09:42:38.937631537Z 	config.action.reload = restart
2025-10-23T09:42:38.937633699Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.937635710Z 	connector.plugin.version = null
2025-10-23T09:42:38.937638110Z 	errors.log.enable = false
2025-10-23T09:42:38.937640094Z 	errors.log.include.messages = false
2025-10-23T09:42:38.937641933Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.937646470Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.937648402Z 	errors.tolerance = none
2025-10-23T09:42:38.937650322Z 	header.converter = null
2025-10-23T09:42:38.937652091Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.937653978Z 	key.converter = null
2025-10-23T09:42:38.937655855Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.937657649Z 	name = pg-connector
2025-10-23T09:42:38.937659585Z 	predicates = []
2025-10-23T09:42:38.937661290Z 	tasks.max = 1
2025-10-23T09:42:38.937663042Z 	tasks.max.enforce = true
2025-10-23T09:42:38.937665151Z 	transforms = []
2025-10-23T09:42:38.937666958Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.937668862Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.937670700Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.937701261Z 2025-10-23T09:42:38,937 INFO   ||  TaskConfig values: 
2025-10-23T09:42:38.937713213Z 	task.class = class io.debezium.connector.postgresql.PostgresConnectorTask
2025-10-23T09:42:38.937716133Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.938226004Z 2025-10-23T09:42:38,938 INFO   ||  Instantiated task pg-connector-0 with version 3.3.1.Final of type io.debezium.connector.postgresql.PostgresConnectorTask   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.938444262Z 2025-10-23T09:42:38,938 INFO   ||  JsonConverterConfig values: 
2025-10-23T09:42:38.938455853Z 	converter.type = value
2025-10-23T09:42:38.938459408Z 	decimal.format = BASE64
2025-10-23T09:42:38.938461648Z 	replace.null.with.default = true
2025-10-23T09:42:38.938463888Z 	schemas.cache.size = 1000
2025-10-23T09:42:38.938466072Z 	schemas.enable = true
2025-10-23T09:42:38.938467889Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.938565736Z 2025-10-23T09:42:38,938 INFO   ||  JsonConverterConfig values: 
2025-10-23T09:42:38.938572770Z 	converter.type = key
2025-10-23T09:42:38.938575926Z 	decimal.format = BASE64
2025-10-23T09:42:38.938578048Z 	replace.null.with.default = true
2025-10-23T09:42:38.938580175Z 	schemas.cache.size = 1000
2025-10-23T09:42:38.938582152Z 	schemas.enable = true
2025-10-23T09:42:38.938583984Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.938594927Z 2025-10-23T09:42:38,938 INFO   ||  Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task pg-connector-0 using the worker config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.938604883Z 2025-10-23T09:42:38,938 INFO   ||  Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task pg-connector-0 using the connector config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.938642810Z 2025-10-23T09:42:38,938 INFO   ||  Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task pg-connector-0 using the worker config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.938869183Z 2025-10-23T09:42:38,938 INFO   ||  Initializing: org.apache.kafka.connect.runtime.TransformationChain{}   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:42:38.939277968Z 2025-10-23T09:42:38,939 INFO   ||  SourceConnectorConfig values: 
2025-10-23T09:42:38.939290473Z 	config.action.reload = restart
2025-10-23T09:42:38.939293238Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.939295261Z 	connector.plugin.version = null
2025-10-23T09:42:38.939297310Z 	errors.log.enable = false
2025-10-23T09:42:38.939299124Z 	errors.log.include.messages = false
2025-10-23T09:42:38.939301070Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.939315225Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.939317632Z 	errors.tolerance = none
2025-10-23T09:42:38.939319576Z 	exactly.once.support = requested
2025-10-23T09:42:38.939321327Z 	header.converter = null
2025-10-23T09:42:38.939323186Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.939325126Z 	key.converter = null
2025-10-23T09:42:38.939326829Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.939328532Z 	name = pg-connector
2025-10-23T09:42:38.939330427Z 	offsets.storage.topic = null
2025-10-23T09:42:38.939332165Z 	predicates = []
2025-10-23T09:42:38.939333897Z 	tasks.max = 1
2025-10-23T09:42:38.939335588Z 	tasks.max.enforce = true
2025-10-23T09:42:38.939337282Z 	topic.creation.groups = []
2025-10-23T09:42:38.939339035Z 	transaction.boundary = poll
2025-10-23T09:42:38.939340873Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.939342631Z 	transforms = []
2025-10-23T09:42:38.939344520Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.939346373Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.939348170Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.939444831Z 2025-10-23T09:42:38,939 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T09:42:38.939458103Z 	config.action.reload = restart
2025-10-23T09:42:38.939461482Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.939463720Z 	connector.plugin.version = null
2025-10-23T09:42:38.939465840Z 	errors.log.enable = false
2025-10-23T09:42:38.939467759Z 	errors.log.include.messages = false
2025-10-23T09:42:38.939469652Z 	errors.retry.delay.max.ms = 60000
2025-10-23T09:42:38.939471482Z 	errors.retry.timeout = 0
2025-10-23T09:42:38.939473261Z 	errors.tolerance = none
2025-10-23T09:42:38.939475055Z 	exactly.once.support = requested
2025-10-23T09:42:38.939476917Z 	header.converter = null
2025-10-23T09:42:38.939478740Z 	header.converter.plugin.version = null
2025-10-23T09:42:38.939480592Z 	key.converter = null
2025-10-23T09:42:38.939482358Z 	key.converter.plugin.version = null
2025-10-23T09:42:38.939484231Z 	name = pg-connector
2025-10-23T09:42:38.939486145Z 	offsets.storage.topic = null
2025-10-23T09:42:38.939488202Z 	predicates = []
2025-10-23T09:42:38.939490197Z 	tasks.max = 1
2025-10-23T09:42:38.939492101Z 	tasks.max.enforce = true
2025-10-23T09:42:38.939493902Z 	topic.creation.groups = []
2025-10-23T09:42:38.939505844Z 	transaction.boundary = poll
2025-10-23T09:42:38.939508282Z 	transaction.boundary.interval.ms = null
2025-10-23T09:42:38.939510270Z 	transforms = []
2025-10-23T09:42:38.939512074Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.939513895Z 	value.converter.plugin.version = null
2025-10-23T09:42:38.939515904Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.939750135Z 2025-10-23T09:42:38,939 INFO   ||  ProducerConfig values: 
2025-10-23T09:42:38.939757411Z 	acks = -1
2025-10-23T09:42:38.939759760Z 	batch.size = 16384
2025-10-23T09:42:38.939761799Z 	bootstrap.servers = [kafka:29092]
2025-10-23T09:42:38.939763559Z 	buffer.memory = 134217728
2025-10-23T09:42:38.939765269Z 	client.dns.lookup = use_all_dns_ips
2025-10-23T09:42:38.939767131Z 	client.id = connector-producer-pg-connector-0
2025-10-23T09:42:38.939769002Z 	compression.gzip.level = -1
2025-10-23T09:42:38.939770969Z 	compression.lz4.level = 9
2025-10-23T09:42:38.939772829Z 	compression.type = none
2025-10-23T09:42:38.939774541Z 	compression.zstd.level = 3
2025-10-23T09:42:38.939776242Z 	connections.max.idle.ms = 540000
2025-10-23T09:42:38.939777988Z 	delivery.timeout.ms = 2147483647
2025-10-23T09:42:38.939779676Z 	enable.idempotence = false
2025-10-23T09:42:38.939781451Z 	enable.metrics.push = true
2025-10-23T09:42:38.939783209Z 	interceptor.classes = []
2025-10-23T09:42:38.939785093Z 	key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2025-10-23T09:42:38.939787020Z 	linger.ms = 5
2025-10-23T09:42:38.939788921Z 	max.block.ms = 9223372036854775807
2025-10-23T09:42:38.939790798Z 	max.in.flight.requests.per.connection = 1
2025-10-23T09:42:38.939792517Z 	max.request.size = 159977748
2025-10-23T09:42:38.939794367Z 	metadata.max.age.ms = 300000
2025-10-23T09:42:38.939796371Z 	metadata.max.idle.ms = 300000
2025-10-23T09:42:38.939798244Z 	metadata.recovery.rebootstrap.trigger.ms = 300000
2025-10-23T09:42:38.939800036Z 	metadata.recovery.strategy = rebootstrap
2025-10-23T09:42:38.939801812Z 	metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
2025-10-23T09:42:38.939803903Z 	metrics.num.samples = 2
2025-10-23T09:42:38.939805676Z 	metrics.recording.level = INFO
2025-10-23T09:42:38.939807414Z 	metrics.sample.window.ms = 30000
2025-10-23T09:42:38.939809121Z 	partitioner.adaptive.partitioning.enable = true
2025-10-23T09:42:38.939810929Z 	partitioner.availability.timeout.ms = 0
2025-10-23T09:42:38.939819452Z 	partitioner.class = null
2025-10-23T09:42:38.939821965Z 	partitioner.ignore.keys = false
2025-10-23T09:42:38.939823812Z 	receive.buffer.bytes = 32768
2025-10-23T09:42:38.939825564Z 	reconnect.backoff.max.ms = 1000
2025-10-23T09:42:38.939827351Z 	reconnect.backoff.ms = 50
2025-10-23T09:42:38.939829939Z 	request.timeout.ms = 30000
2025-10-23T09:42:38.939831712Z 	retries = 2147483647
2025-10-23T09:42:38.939833585Z 	retry.backoff.max.ms = 1000
2025-10-23T09:42:38.939835363Z 	retry.backoff.ms = 100
2025-10-23T09:42:38.939837190Z 	sasl.client.callback.handler.class = null
2025-10-23T09:42:38.939838949Z 	sasl.jaas.config = null
2025-10-23T09:42:38.939840630Z 	sasl.kerberos.kinit.cmd = /usr/bin/kinit
2025-10-23T09:42:38.939842536Z 	sasl.kerberos.min.time.before.relogin = 60000
2025-10-23T09:42:38.939844348Z 	sasl.kerberos.service.name = null
2025-10-23T09:42:38.939846235Z 	sasl.kerberos.ticket.renew.jitter = 0.05
2025-10-23T09:42:38.939848127Z 	sasl.kerberos.ticket.renew.window.factor = 0.8
2025-10-23T09:42:38.939849856Z 	sasl.login.callback.handler.class = null
2025-10-23T09:42:38.939851576Z 	sasl.login.class = null
2025-10-23T09:42:38.939853217Z 	sasl.login.connect.timeout.ms = null
2025-10-23T09:42:38.939854878Z 	sasl.login.read.timeout.ms = null
2025-10-23T09:42:38.939856719Z 	sasl.login.refresh.buffer.seconds = 300
2025-10-23T09:42:38.939858505Z 	sasl.login.refresh.min.period.seconds = 60
2025-10-23T09:42:38.939860205Z 	sasl.login.refresh.window.factor = 0.8
2025-10-23T09:42:38.939861879Z 	sasl.login.refresh.window.jitter = 0.05
2025-10-23T09:42:38.939863591Z 	sasl.login.retry.backoff.max.ms = 10000
2025-10-23T09:42:38.939865289Z 	sasl.login.retry.backoff.ms = 100
2025-10-23T09:42:38.939867114Z 	sasl.mechanism = GSSAPI
2025-10-23T09:42:38.939869524Z 	sasl.oauthbearer.assertion.algorithm = RS256
2025-10-23T09:42:38.939871444Z 	sasl.oauthbearer.assertion.claim.aud = null
2025-10-23T09:42:38.939873233Z 	sasl.oauthbearer.assertion.claim.exp.seconds = 300
2025-10-23T09:42:38.939875030Z 	sasl.oauthbearer.assertion.claim.iss = null
2025-10-23T09:42:38.939876871Z 	sasl.oauthbearer.assertion.claim.jti.include = false
2025-10-23T09:42:38.939878763Z 	sasl.oauthbearer.assertion.claim.nbf.seconds = 60
2025-10-23T09:42:38.939880726Z 	sasl.oauthbearer.assertion.claim.sub = null
2025-10-23T09:42:38.939882470Z 	sasl.oauthbearer.assertion.file = null
2025-10-23T09:42:38.939884316Z 	sasl.oauthbearer.assertion.private.key.file = null
2025-10-23T09:42:38.939889415Z 	sasl.oauthbearer.assertion.private.key.passphrase = null
2025-10-23T09:42:38.939891718Z 	sasl.oauthbearer.assertion.template.file = null
2025-10-23T09:42:38.939893566Z 	sasl.oauthbearer.client.credentials.client.id = null
2025-10-23T09:42:38.939895428Z 	sasl.oauthbearer.client.credentials.client.secret = null
2025-10-23T09:42:38.939897334Z 	sasl.oauthbearer.clock.skew.seconds = 30
2025-10-23T09:42:38.939899147Z 	sasl.oauthbearer.expected.audience = null
2025-10-23T09:42:38.939901021Z 	sasl.oauthbearer.expected.issuer = null
2025-10-23T09:42:38.939966452Z 	sasl.oauthbearer.header.urlencode = false
2025-10-23T09:42:38.939970268Z 	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2025-10-23T09:42:38.939972397Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2025-10-23T09:42:38.939974544Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2025-10-23T09:42:38.939976474Z 	sasl.oauthbearer.jwks.endpoint.url = null
2025-10-23T09:42:38.939978455Z 	sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
2025-10-23T09:42:38.939980689Z 	sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
2025-10-23T09:42:38.939982688Z 	sasl.oauthbearer.scope = null
2025-10-23T09:42:38.939984663Z 	sasl.oauthbearer.scope.claim.name = scope
2025-10-23T09:42:38.939986553Z 	sasl.oauthbearer.sub.claim.name = sub
2025-10-23T09:42:38.939988296Z 	sasl.oauthbearer.token.endpoint.url = null
2025-10-23T09:42:38.939990092Z 	security.protocol = PLAINTEXT
2025-10-23T09:42:38.939991864Z 	security.providers = null
2025-10-23T09:42:38.939993791Z 	send.buffer.bytes = 131072
2025-10-23T09:42:38.939995538Z 	socket.connection.setup.timeout.max.ms = 30000
2025-10-23T09:42:38.939997454Z 	socket.connection.setup.timeout.ms = 10000
2025-10-23T09:42:38.939999392Z 	ssl.cipher.suites = null
2025-10-23T09:42:38.940001069Z 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2025-10-23T09:42:38.940002815Z 	ssl.endpoint.identification.algorithm = https
2025-10-23T09:42:38.940004664Z 	ssl.engine.factory.class = null
2025-10-23T09:42:38.940006445Z 	ssl.key.password = null
2025-10-23T09:42:38.940008206Z 	ssl.keymanager.algorithm = SunX509
2025-10-23T09:42:38.940010513Z 	ssl.keystore.certificate.chain = null
2025-10-23T09:42:38.940012292Z 	ssl.keystore.key = null
2025-10-23T09:42:38.940014020Z 	ssl.keystore.location = null
2025-10-23T09:42:38.940015960Z 	ssl.keystore.password = null
2025-10-23T09:42:38.940017845Z 	ssl.keystore.type = JKS
2025-10-23T09:42:38.940023261Z 	ssl.protocol = TLSv1.3
2025-10-23T09:42:38.940025652Z 	ssl.provider = null
2025-10-23T09:42:38.940027558Z 	ssl.secure.random.implementation = null
2025-10-23T09:42:38.940030288Z 	ssl.trustmanager.algorithm = PKIX
2025-10-23T09:42:38.940032261Z 	ssl.truststore.certificates = null
2025-10-23T09:42:38.940034052Z 	ssl.truststore.location = null
2025-10-23T09:42:38.940035826Z 	ssl.truststore.password = null
2025-10-23T09:42:38.940037641Z 	ssl.truststore.type = JKS
2025-10-23T09:42:38.940039441Z 	transaction.timeout.ms = 60000
2025-10-23T09:42:38.940041183Z 	transaction.two.phase.commit.enable = false
2025-10-23T09:42:38.940042946Z 	transactional.id = null
2025-10-23T09:42:38.940044682Z 	value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2025-10-23T09:42:38.940046566Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.940048524Z 2025-10-23T09:42:38,939 INFO   ||  initializing Kafka metrics collector   [org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector]
2025-10-23T09:42:38.942455923Z 2025-10-23T09:42:38,942 INFO   ||  These configurations '[metrics.context.connect.group.id, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet.   [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T09:42:38.942524696Z 2025-10-23T09:42:38,942 INFO   ||  Kafka version: 4.1.0   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T09:42:38.942534391Z 2025-10-23T09:42:38,942 INFO   ||  Kafka commitId: 13f70256db3c994c   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T09:42:38.942536874Z 2025-10-23T09:42:38,942 INFO   ||  Kafka startTimeMs: 1761212558942   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T09:42:38.943506102Z 2025-10-23T09:42:38,943 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:42:38.943536956Z 2025-10-23T09:42:38,943 INFO   ||  You are using a no-op lineage emitter. If you want to emit open lineage event, please set 'openlineage.integration.enabled=true'   [io.debezium.openlineage.emitter.NoOpLineageEmitter]
2025-10-23T09:42:38.944356687Z 2025-10-23T09:42:38,944 INFO   ||  Starting PostgresConnectorTask with configuration:
2025-10-23T09:42:38.944388043Z    connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T09:42:38.944392346Z    database.user = postgres
2025-10-23T09:42:38.944394679Z    database.dbname = postgres
2025-10-23T09:42:38.944396598Z    slot.name = dbname_debezium
2025-10-23T09:42:38.944398498Z    publication.name = dbname_publication
2025-10-23T09:42:38.944400570Z    database.server.name = pg-dev
2025-10-23T09:42:38.944402538Z    heartbeat.interval.ms = 5000
2025-10-23T09:42:38.944404489Z    buffer.memory = 259977748
2025-10-23T09:42:38.944406286Z    plugin.name = pgoutput
2025-10-23T09:42:38.944424354Z    database.port = 5432
2025-10-23T09:42:38.944426794Z    key.converter.schemas.enable = false
2025-10-23T09:42:38.944428702Z    max.request.size = 159977748
2025-10-23T09:42:38.944430506Z    topic.prefix = pg-dev
2025-10-23T09:42:38.944432354Z    task.class = io.debezium.connector.postgresql.PostgresConnectorTask
2025-10-23T09:42:38.944434258Z    database.hostname = postgres
2025-10-23T09:42:38.944436110Z    database.password = ********
2025-10-23T09:42:38.944438098Z    value.converter.schemas.enable = true
2025-10-23T09:42:38.944439933Z    name = pg-connector
2025-10-23T09:42:38.944441720Z    table.include.list = public.(.*)
2025-10-23T09:42:38.944443632Z    value.converter = org.apache.kafka.connect.json.JsonConverter
2025-10-23T09:42:38.944445611Z    snapshot.mode = no_data
2025-10-23T09:42:38.944447739Z    [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:42:38.944573597Z 2025-10-23T09:42:38,944 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2025-10-23T09:42:38.945207319Z 2025-10-23T09:42:38,945 INFO   ||  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2025-10-23T09:42:38.945502043Z 2025-10-23T09:42:38,945 INFO   ||  [Producer clientId=connector-producer-pg-connector-0] Cluster ID: 3aWVlgGFSqefKV6stX0huQ   [org.apache.kafka.clients.Metadata]
2025-10-23T09:42:38.952359398Z 2025-10-23T09:42:38,952 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:38.952484839Z 2025-10-23T09:42:38,952 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:38.953066838Z 2025-10-23T09:42:38,952 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:38.970745463Z 2025-10-23T09:42:38,970 WARN   ||  Type [oid:13552, name:_pg_user_mappings] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.970789842Z 2025-10-23T09:42:38,970 WARN   ||  Type [oid:16405, name:bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.970796314Z 2025-10-23T09:42:38,970 WARN   ||  Type [oid:16404, name:_bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.970820395Z 2025-10-23T09:42:38,970 WARN   ||  Type [oid:16414, name:foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.970835079Z 2025-10-23T09:42:38,970 WARN   ||  Type [oid:16413, name:_foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971522962Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:26493, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971579047Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:26492, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971731403Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35182, name:dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971756345Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35181, name:_dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971825335Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35283, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971840767Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35282, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971887372Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35396, name:db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971906616Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35395, name:_db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971917182Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35401, name:db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971931848Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35400, name:_db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971968744Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35404, name:async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971975304Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35403, name:_async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971995509Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35409, name:async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.971997316Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35408, name:_async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972036874Z 2025-10-23T09:42:38,971 WARN   ||  Type [oid:35414, name:async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972042985Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35413, name:_async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972062208Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35419, name:async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972094074Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35418, name:_async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972125018Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35424, name:async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972145934Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35423, name:_async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972186651Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35427, name:async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972201897Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35426, name:_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972216516Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35432, name:async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972229621Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35431, name:_async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972253051Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35437, name:async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972271214Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35436, name:_async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972293557Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35442, name:async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972409226Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35441, name:_async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972421216Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35445, name:temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972428855Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35444, name:_temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972501913Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35448, name:async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972509149Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35447, name:_async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972526059Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35451, name:ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972537583Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35450, name:_ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972553602Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35456, name:temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972568780Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:35455, name:_temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972594182Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:46622, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972608295Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:46621, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972650835Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:13226, name:cardinal_number] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972697582Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:13229, name:character_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972703762Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:13231, name:sql_identifier] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972712609Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:13237, name:time_stamp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.972772112Z 2025-10-23T09:42:38,972 WARN   ||  Type [oid:13239, name:yes_or_no] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.977354700Z 2025-10-23T09:42:38,977 INFO   ||  Found previous partition offset PostgresPartition [sourcePartition={server=pg-dev}]: {lsn_proc=49928494016, messageType=COMMIT, lsn_commit=49928494016, lsn=49928494016, txId=260746, ts_usec=1761212483549192}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:42:38.996307445Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:13552, name:_pg_user_mappings] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.996331283Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:16405, name:bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.996384218Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:16404, name:_bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.996421187Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:16414, name:foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.996446350Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:16413, name:_foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.996999893Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:26493, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997014297Z 2025-10-23T09:42:38,996 WARN   ||  Type [oid:26492, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997282568Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35182, name:dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997305997Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35181, name:_dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997347287Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35283, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997357996Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35282, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997431531Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35396, name:db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997440994Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35395, name:_db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997445166Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35401, name:db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997486787Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35400, name:_db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997551355Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35404, name:async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997557729Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35403, name:_async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997559173Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35409, name:async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997574635Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35408, name:_async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997585311Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35414, name:async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997600107Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35413, name:_async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997619559Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35419, name:async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997676151Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35418, name:_async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997680629Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35424, name:async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997683576Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35423, name:_async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997704624Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35427, name:async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997714828Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35426, name:_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997736731Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35432, name:async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997740498Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35431, name:_async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997799328Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35437, name:async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997802638Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35436, name:_async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997804688Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35442, name:async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997873436Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35441, name:_async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997891455Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35445, name:temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997919218Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35444, name:_temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997934817Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35448, name:async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997950626Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35447, name:_async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.997998072Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35451, name:ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998024210Z 2025-10-23T09:42:38,997 WARN   ||  Type [oid:35450, name:_ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998031522Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:35456, name:temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998051256Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:35455, name:_temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998063761Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:46622, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998094847Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:46621, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998137390Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:13226, name:cardinal_number] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998150328Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:13229, name:character_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998245177Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:13231, name:sql_identifier] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998255744Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:13237, name:time_stamp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:38.998281635Z 2025-10-23T09:42:38,998 WARN   ||  Type [oid:13239, name:yes_or_no] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T09:42:39.000605854Z 2025-10-23T09:42:39,000 INFO   ||  Guardrail validation skipped   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T09:42:39.002327516Z 2025-10-23T09:42:39,002 INFO   ||  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF85BC0}, catalogXmin=260747]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T09:42:39.002355953Z 2025-10-23T09:42:39,002 INFO   ||  Slot 'dbname_debezium' has restart LSN 'LSN{B/9FF85BC0}'   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T09:42:39.002551923Z 2025-10-23T09:42:39,002 INFO   Postgres||postgres-connector-task  Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='pg-dev'db='postgres', lsn=LSN{B/9FF85BC0}, txId=260746, messageType=COMMIT, lastCommitLsn=LSN{B/9FF85BC0}, timestamp=2025-10-23T09:41:23.549192Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{B/9FF85BC0}, lastCommitLsn=LSN{B/9FF85BC0}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T09:42:39.003876547Z 2025-10-23T09:42:39,003 INFO   Postgres||postgres-connector-task  user 'postgres' connected to database 'postgres' on PostgreSQL 16.5 (Debian 16.5-1.pgdg120+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 12.2.0-14) 12.2.0, 64-bit with roles:
2025-10-23T09:42:39.003902988Z 	role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003907142Z 	role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003909760Z 	role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003912492Z 	role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003914686Z 	role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003916904Z 	role 'pg_use_reserved_connections' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003919097Z 	role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003921310Z 	role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003923700Z 	role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003926195Z 	role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003931222Z 	role 'pg_create_subscription' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003933716Z 	role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003937240Z 	role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003939648Z 	role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T09:42:39.003952475Z 	role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T09:42:39.004710772Z 2025-10-23T09:42:39,004 INFO   Postgres||postgres-connector-task  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF85BC0}, catalogXmin=260747]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T09:42:39.005597610Z 2025-10-23T09:42:39,005 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = SignalProcessor   [io.debezium.util.Threads]
2025-10-23T09:42:39.006060085Z 2025-10-23T09:42:39,006 INFO   Postgres||postgres-connector-task  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2025-10-23T09:42:39.006575939Z 2025-10-23T09:42:39,006 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = change-event-source-coordinator   [io.debezium.util.Threads]
2025-10-23T09:42:39.006642105Z 2025-10-23T09:42:39,006 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = blocking-snapshot   [io.debezium.util.Threads]
2025-10-23T09:42:39.006761368Z 2025-10-23T09:42:39,006 INFO   Postgres||postgres-connector-task  Creating thread debezium-postgresconnector-pg-dev-change-event-source-coordinator   [io.debezium.util.Threads]
2025-10-23T09:42:39.007017229Z 2025-10-23T09:42:39,006 INFO   ||  WorkerSourceTask{id=pg-connector-0} Source task finished initialization and start   [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask]
2025-10-23T09:42:39.007545574Z 2025-10-23T09:42:39,007 INFO   Postgres||snapshot  Metrics registered   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:39.007576768Z 2025-10-23T09:42:39,007 INFO   Postgres||snapshot  Context created   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:39.007649218Z 2025-10-23T09:42:39,007 INFO   Postgres||snapshot  A previous offset indicating a completed snapshot has been found.   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2025-10-23T09:42:39.007685496Z 2025-10-23T09:42:39,007 INFO   Postgres||snapshot  According to the connector configuration no snapshot will be executed   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2025-10-23T09:42:39.008202899Z 2025-10-23T09:42:39,007 INFO   Postgres||snapshot  Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='pg-dev'db='postgres', lsn=LSN{B/9FF85BC0}, txId=260746, messageType=COMMIT, lastCommitLsn=LSN{B/9FF85BC0}, timestamp=2025-10-23T09:41:23.549192Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{B/9FF85BC0}, lastCommitLsn=LSN{B/9FF85BC0}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:39.008469430Z 2025-10-23T09:42:39,008 INFO   Postgres||streaming  Requested thread factory for component PostgresStreamingChangeEventSource, id = pg-dev named = lsn-flush   [io.debezium.util.Threads]
2025-10-23T09:42:39.008546554Z 2025-10-23T09:42:39,008 INFO   Postgres||streaming  Connected metrics set to 'true'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:39.035874585Z 2025-10-23T09:42:39,035 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.bar' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T09:42:39.036441545Z 2025-10-23T09:42:39,036 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.with_default' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T09:42:39.036968999Z 2025-10-23T09:42:39,036 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.foo' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T09:42:39.037498280Z 2025-10-23T09:42:39,037 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.f_ch_one_sided_result_temp' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T09:42:39.039835665Z 2025-10-23T09:42:39,039 INFO   Postgres||streaming  SignalProcessor started. Scheduling it every 5000ms   [io.debezium.pipeline.signal.SignalProcessor]
2025-10-23T09:42:39.039868228Z 2025-10-23T09:42:39,039 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-SignalProcessor   [io.debezium.util.Threads]
2025-10-23T09:42:39.040051220Z 2025-10-23T09:42:39,040 INFO   Postgres||streaming  Starting streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:42:39.040181892Z 2025-10-23T09:42:39,040 INFO   Postgres||streaming  Retrieved latest position from stored offset 'LSN{B/9FF85BC0}'   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T09:42:39.040243236Z 2025-10-23T09:42:39,040 INFO   Postgres||streaming  Looking for WAL restart position for last commit LSN 'LSN{B/9FF85BC0}' and last change LSN 'LSN{B/9FF85BC0}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T09:42:39.040273602Z 2025-10-23T09:42:39,040 INFO   Postgres||streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T09:42:39.055022674Z 2025-10-23T09:42:39,054 INFO   Postgres||streaming  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF85BC0}, catalogXmin=260747]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T09:42:39.055065350Z 2025-10-23T09:42:39,055 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:39.055115559Z 2025-10-23T09:42:39,055 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:39.055612949Z 2025-10-23T09:42:39,055 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:39.067220864Z 2025-10-23T09:42:39,067 INFO   Postgres||streaming  Requested thread factory for component PostgresConnector, id = pg-dev named = keep-alive   [io.debezium.util.Threads]
2025-10-23T09:42:39.067285131Z 2025-10-23T09:42:39,067 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-keep-alive   [io.debezium.util.Threads]
2025-10-23T09:42:39.067711162Z 2025-10-23T09:42:39,067 INFO   Postgres||streaming  Searching for WAL resume position   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T09:42:43.827830133Z 2025-10-23T09:42:43,827 INFO   ||  172.17.0.1 - - [23/Oct/2025:09:42:43 +0000] "GET /connectors/pg-connector/status HTTP/1.1" 200 216 "" "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/141.0.0.0 Safari/537.36" 4   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T09:42:44.518203514Z 2025-10-23T09:42:44,518 INFO   ||  1 records sent during previous 00:00:05.58, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494016, messageType=COMMIT, lsn_commit=49928494016, lsn=49928494016, txId=260746, ts_usec=1761212483549192}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:42:45.370189747Z 2025-10-23T09:42:45,370 INFO   ||  172.17.0.1 - - [23/Oct/2025:09:42:45 +0000] "GET /connectors/pg-connector/status HTTP/1.1" 200 216 "" "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/141.0.0.0 Safari/537.36" 3   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T09:42:53.733372805Z 2025-10-23T09:42:53,732 INFO   Postgres||streaming  First LSN 'LSN{B/9FF85BF8}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T09:42:53.738335525Z 2025-10-23T09:42:53,738 INFO   Postgres||streaming  Received COMMIT LSN 'LSN{B/9FF85CA8}' larger than than last stored commit LSN 'LSN{B/9FF85BC0}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T09:42:53.738395928Z 2025-10-23T09:42:53,738 INFO   Postgres||streaming  Will restart from LSN 'LSN{B/9FF85BF8}' that is start of the first unprocessed transaction   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T09:42:53.738437097Z 2025-10-23T09:42:53,738 INFO   Postgres||streaming  WAL resume position 'LSN{B/9FF85BF8}' discovered   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T09:42:53.738850659Z 2025-10-23T09:42:53,738 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:53.738909754Z 2025-10-23T09:42:53,738 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:53.738987978Z 2025-10-23T09:42:53,738 ERROR  ||  Unexpected exception while performing keepalive status update on the replication stream   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T09:42:53.739015644Z java.lang.InterruptedException: sleep interrupted
2025-10-23T09:42:53.739028251Z 	at java.base/java.lang.Thread.sleep0(Native Method) ~[?:?]
2025-10-23T09:42:53.739030799Z 	at java.base/java.lang.Thread.sleep(Thread.java:509) [?:?]
2025-10-23T09:42:53.739033905Z 	at io.debezium.util.Metronome$1.pause(Metronome.java:57) ~[debezium-core-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:42:53.739045707Z 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:1007) ~[debezium-connector-postgres-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:42:53.739047128Z 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
2025-10-23T09:42:53.739048252Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
2025-10-23T09:42:53.739049341Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
2025-10-23T09:42:53.739050487Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
2025-10-23T09:42:53.739051595Z 	at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
2025-10-23T09:42:53.739383273Z 2025-10-23T09:42:53,739 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:53.739478093Z 2025-10-23T09:42:53,739 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:53.739480541Z 2025-10-23T09:42:53,739 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:42:53.739885679Z 2025-10-23T09:42:53,739 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:42:53.745230570Z 2025-10-23T09:42:53,745 INFO   Postgres||streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T09:42:53.756634010Z 2025-10-23T09:42:53,756 INFO   Postgres||streaming  Requested thread factory for component PostgresConnector, id = pg-dev named = keep-alive   [io.debezium.util.Threads]
2025-10-23T09:42:53.756667294Z 2025-10-23T09:42:53,756 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-keep-alive   [io.debezium.util.Threads]
2025-10-23T09:42:53.756873400Z 2025-10-23T09:42:53,756 INFO   Postgres||streaming  Processing messages   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T09:42:53.756981396Z 2025-10-23T09:42:53,756 INFO   Postgres||streaming  Message with LSN 'LSN{B/9FF85BF8}' arrived, switching off the filtering   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T09:42:54.038191742Z 2025-10-23T09:42:54,038 INFO   ||  2 records sent during previous 00:00:09.52, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494072, messageType=INSERT, lsn_commit=49928494016, lsn=49928494072, txId=260747, ts_usec=1761212573237248}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:43:14.580197154Z 2025-10-23T09:43:14,580 INFO   ||  5 records sent during previous 00:00:20.542, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494248, messageType=COMMIT, lsn_commit=49928494248, lsn=49928494248, txId=260747, ts_usec=1761212573237248}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:43:38.943624428Z 2025-10-23T09:43:38,943 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:43:39.130803232Z 2025-10-23T09:43:39,130 INFO   ||  Creating thread debezium-postgresstreamingchangeeventsource-pg-dev-lsn-flush   [io.debezium.util.Threads]
2025-10-23T09:43:55.163254526Z 2025-10-23T09:43:55,163 INFO   ||  8 records sent during previous 00:00:40.583, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494248, messageType=COMMIT, lsn_commit=49928494248, lsn=49928494248, txId=260747, ts_usec=1761212573237248}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:44:38.949467793Z 2025-10-23T09:44:38,949 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:45:16.326220997Z 2025-10-23T09:45:16,326 INFO   ||  16 records sent during previous 00:01:21.163, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928494248, messageType=COMMIT, lsn_commit=49928494248, lsn=49928494248, txId=260747, ts_usec=1761212573237248}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:45:38.956108316Z 2025-10-23T09:45:38,955 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:46:38.971237626Z 2025-10-23T09:46:38,971 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:47:38.977786619Z 2025-10-23T09:47:38,977 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:47:57.651230295Z 2025-10-23T09:47:57,651 INFO   ||  33 records sent during previous 00:02:41.325, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928520864, messageType=COMMIT, lsn_commit=49928520864, lsn=49928520864, txId=260750, ts_usec=1761212863131177}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:48:38.983430791Z 2025-10-23T09:48:38,983 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 13 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:49:38.990125657Z 2025-10-23T09:49:38,989 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 11 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:50:38.996500692Z 2025-10-23T09:50:38,996 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:51:39.011526548Z 2025-10-23T09:51:39,002 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:52:39.017886196Z 2025-10-23T09:52:39,017 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:53:16.292202776Z 2025-10-23T09:53:16,292 INFO   ||  63 records sent during previous 00:05:18.641, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928520864, messageType=COMMIT, lsn_commit=49928520864, lsn=49928520864, txId=260750, ts_usec=1761212863131177}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:53:39.023509964Z 2025-10-23T09:53:39,023 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:54:39.030167458Z 2025-10-23T09:54:39,029 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:55:39.036755198Z 2025-10-23T09:55:39,036 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:56:39.043218706Z 2025-10-23T09:56:39,043 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 11 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:57:27.951270116Z 2025-10-23T09:57:27,951 INFO   ||  Successfully processed removal of connector 'pg-connector'   [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
2025-10-23T09:57:27.951312773Z 2025-10-23T09:57:27,951 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Connector pg-connector config removed   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:27.952144397Z 2025-10-23T09:57:27,952 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:27.952164623Z 2025-10-23T09:57:27,952 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:27.953008757Z 2025-10-23T09:57:27,952 INFO   ||  172.17.0.1 - - [23/Oct/2025:09:57:27 +0000] "DELETE /connectors/pg-connector HTTP/1.1" 204 0 "" "curl/8.11.1" 11   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T09:57:27.954009764Z 2025-10-23T09:57:27,953 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=14, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:27.955972290Z 2025-10-23T09:57:27,955 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=14, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:27.956195354Z 2025-10-23T09:57:27,956 INFO   ||  Stopping connector pg-connector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:57:27.956210712Z 2025-10-23T09:57:27,956 INFO   ||  Stopping task pg-connector-0   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T09:57:27.956213136Z 2025-10-23T09:57:27,956 INFO   ||  Scheduled shutdown for WorkerConnector{id=pg-connector}   [org.apache.kafka.connect.runtime.WorkerConnector]
2025-10-23T09:57:27.957291796Z 2025-10-23T09:57:27,957 INFO   ||  Completed shutdown for WorkerConnector{id=pg-connector}   [org.apache.kafka.connect.runtime.WorkerConnector]
2025-10-23T09:57:28.299216410Z 2025-10-23T09:57:28,299 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 10 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T09:57:28.307397887Z 2025-10-23T09:57:28,307 INFO   ||  Stopping down connector   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T09:57:28.453230886Z 2025-10-23T09:57:28,453 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.453267624Z 2025-10-23T09:57:28,453 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.453338866Z 2025-10-23T09:57:28,453 ERROR  ||  Unexpected exception while performing keepalive status update on the replication stream   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T09:57:28.453344273Z java.lang.InterruptedException: sleep interrupted
2025-10-23T09:57:28.453346664Z 	at java.base/java.lang.Thread.sleep0(Native Method) ~[?:?]
2025-10-23T09:57:28.453349100Z 	at java.base/java.lang.Thread.sleep(Thread.java:509) [?:?]
2025-10-23T09:57:28.453351157Z 	at io.debezium.util.Metronome$1.pause(Metronome.java:57) ~[debezium-core-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:57:28.453353195Z 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:1007) ~[debezium-connector-postgres-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T09:57:28.453355325Z 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
2025-10-23T09:57:28.453357203Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
2025-10-23T09:57:28.453362007Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
2025-10-23T09:57:28.453364210Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
2025-10-23T09:57:28.453366199Z 	at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
2025-10-23T09:57:28.453831386Z 2025-10-23T09:57:28,453 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:57:28.453928157Z 2025-10-23T09:57:28,453 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.453979487Z 2025-10-23T09:57:28,453 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.454378796Z 2025-10-23T09:57:28,454 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:57:28.454465198Z 2025-10-23T09:57:28,454 INFO   Postgres||streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:57:28.454589432Z 2025-10-23T09:57:28,454 INFO   Postgres||streaming  Connected metrics set to 'false'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T09:57:28.454745901Z 2025-10-23T09:57:28,454 INFO   ||  SignalProcessor stopped   [io.debezium.pipeline.signal.SignalProcessor]
2025-10-23T09:57:28.454822482Z 2025-10-23T09:57:28,454 INFO   ||  Debezium ServiceRegistry stopped.   [io.debezium.service.DefaultServiceRegistry]
2025-10-23T09:57:28.454966292Z 2025-10-23T09:57:28,454 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.455029907Z 2025-10-23T09:57:28,455 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T09:57:28.455552364Z 2025-10-23T09:57:28,455 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T09:57:28.455836830Z 2025-10-23T09:57:28,455 INFO   ||  [Producer clientId=connector-producer-pg-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2025-10-23T09:57:28.458309528Z 2025-10-23T09:57:28,458 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:57:28.458334845Z 2025-10-23T09:57:28,458 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:57:28.458371410Z 2025-10-23T09:57:28,458 INFO   ||  Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:57:28.458384434Z 2025-10-23T09:57:28,458 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
2025-10-23T09:57:28.458634530Z 2025-10-23T09:57:28,458 INFO   ||  App info kafka.producer for connector-producer-pg-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T09:57:28.459477892Z 2025-10-23T09:57:28,459 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished stopping tasks in preparation for rebalance   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.475209802Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished flushing status backing store in preparation for rebalance   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.475331959Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 14 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=105, connectorIds=[], taskIds=[], revokedConnectorIds=[pg-connector], revokedTaskIds=[pg-connector-0], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.475602460Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 105   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.475623085Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.475661091Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:28.475673105Z 2025-10-23T09:57:28,475 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:28.476781658Z 2025-10-23T09:57:28,476 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=15, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:28.477980042Z 2025-10-23T09:57:28,477 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=15, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T09:57:28.478053252Z 2025-10-23T09:57:28,478 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 15 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=105, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.478251475Z 2025-10-23T09:57:28,478 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 105   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T09:57:28.478277028Z 2025-10-23T09:57:28,478 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:03:07.731961056Z 2025-10-23T10:03:07,731 INFO   ||  [AdminClient clientId=debezium-shared-admin] Rebootstrapping with Cluster(id = null, nodes = [kafka:29092 (id: -1 rack: null isFenced: false)], partitions = [], controller = null)   [org.apache.kafka.clients.admin.internals.AdminMetadataManager]
2025-10-23T10:06:23.073218949Z 2025-10-23T10:06:23,072 INFO   ||  Validating connector io.debezium.connector.postgresql.PostgresConnector, version 3.3.1.Final   [org.apache.kafka.connect.runtime.AbstractHerder]
2025-10-23T10:06:23.074028474Z 2025-10-23T10:06:23,073 INFO   ||  AbstractConfig values: 
2025-10-23T10:06:23.074045900Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.074970152Z 2025-10-23T10:06:23,074 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2025-10-23T10:06:23.075316842Z 2025-10-23T10:06:23,075 INFO   ||  Requested thread factory for component PostgresConnector, id = pg-dev named = connection-validation   [io.debezium.util.Threads]
2025-10-23T10:06:23.075359013Z 2025-10-23T10:06:23,075 INFO   ||  Creating thread debezium-postgresconnector-pg-dev-connection-validation   [io.debezium.util.Threads]
2025-10-23T10:06:23.082510080Z 2025-10-23T10:06:23,082 INFO   ||  Successfully tested connection for jdbc:postgresql://postgres:5432/postgres with user 'postgres'   [io.debezium.connector.postgresql.PostgresConnector]
2025-10-23T10:06:23.084600283Z 2025-10-23T10:06:23,084 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.084658172Z 2025-10-23T10:06:23,084 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.085142784Z 2025-10-23T10:06:23,084 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T10:06:23.093073086Z 2025-10-23T10:06:23,092 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Connector pg-connector config updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.093243197Z 2025-10-23T10:06:23,093 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.093305799Z 2025-10-23T10:06:23,093 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.094827475Z 2025-10-23T10:06:23,094 INFO   ||  172.17.0.1 - - [23/Oct/2025:10:06:23 +0000] "POST /connectors/ HTTP/1.1" 201 707 "" "curl/8.11.1" 24   [org.apache.kafka.connect.runtime.rest.RestServer]
2025-10-23T10:06:23.095450048Z 2025-10-23T10:06:23,095 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=16, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.097114254Z 2025-10-23T10:06:23,097 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=16, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.097248110Z 2025-10-23T10:06:23,097 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 16 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=106, connectorIds=[pg-connector], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.097366660Z 2025-10-23T10:06:23,097 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 106   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.097479225Z 2025-10-23T10:06:23,097 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connector pg-connector   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.097633657Z 2025-10-23T10:06:23,097 INFO   ||  Creating connector pg-connector of type io.debezium.connector.postgresql.PostgresConnector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.098068888Z 2025-10-23T10:06:23,098 INFO   ||  SourceConnectorConfig values: 
2025-10-23T10:06:23.098083943Z 	config.action.reload = restart
2025-10-23T10:06:23.098091259Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.098094519Z 	connector.plugin.version = null
2025-10-23T10:06:23.098097300Z 	errors.log.enable = false
2025-10-23T10:06:23.098099863Z 	errors.log.include.messages = false
2025-10-23T10:06:23.098102433Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.098114432Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.098117495Z 	errors.tolerance = none
2025-10-23T10:06:23.098119979Z 	exactly.once.support = requested
2025-10-23T10:06:23.098122324Z 	header.converter = null
2025-10-23T10:06:23.098124496Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.098126750Z 	key.converter = null
2025-10-23T10:06:23.098129065Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.098131247Z 	name = pg-connector
2025-10-23T10:06:23.098133375Z 	offsets.storage.topic = null
2025-10-23T10:06:23.098135559Z 	predicates = []
2025-10-23T10:06:23.098137725Z 	tasks.max = 1
2025-10-23T10:06:23.098140005Z 	tasks.max.enforce = true
2025-10-23T10:06:23.098142143Z 	topic.creation.groups = []
2025-10-23T10:06:23.098144250Z 	transaction.boundary = poll
2025-10-23T10:06:23.098146449Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.098148775Z 	transforms = []
2025-10-23T10:06:23.098151049Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.098153492Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.098155730Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.098241909Z 2025-10-23T10:06:23,098 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T10:06:23.098248213Z 	config.action.reload = restart
2025-10-23T10:06:23.098251053Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.098253814Z 	connector.plugin.version = null
2025-10-23T10:06:23.098256113Z 	errors.log.enable = false
2025-10-23T10:06:23.098258330Z 	errors.log.include.messages = false
2025-10-23T10:06:23.098260711Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.098262950Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.098265319Z 	errors.tolerance = none
2025-10-23T10:06:23.098267858Z 	exactly.once.support = requested
2025-10-23T10:06:23.098270106Z 	header.converter = null
2025-10-23T10:06:23.098272348Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.098274710Z 	key.converter = null
2025-10-23T10:06:23.098276848Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.098279041Z 	name = pg-connector
2025-10-23T10:06:23.098281114Z 	offsets.storage.topic = null
2025-10-23T10:06:23.098283335Z 	predicates = []
2025-10-23T10:06:23.098285577Z 	tasks.max = 1
2025-10-23T10:06:23.098287981Z 	tasks.max.enforce = true
2025-10-23T10:06:23.098298432Z 	topic.creation.groups = []
2025-10-23T10:06:23.098301419Z 	transaction.boundary = poll
2025-10-23T10:06:23.098304118Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.098306361Z 	transforms = []
2025-10-23T10:06:23.098308565Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.098310889Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.098313111Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.098524708Z 2025-10-23T10:06:23,098 INFO   ||  Instantiated connector pg-connector with version 3.3.1.Final of type class io.debezium.connector.postgresql.PostgresConnector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.098688696Z 2025-10-23T10:06:23,098 INFO   ||  Finished creating connector pg-connector   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.098821723Z 2025-10-23T10:06:23,098 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.099495243Z 2025-10-23T10:06:23,099 INFO   ||  SourceConnectorConfig values: 
2025-10-23T10:06:23.099512963Z 	config.action.reload = restart
2025-10-23T10:06:23.099515370Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.099517383Z 	connector.plugin.version = null
2025-10-23T10:06:23.099519148Z 	errors.log.enable = false
2025-10-23T10:06:23.099520914Z 	errors.log.include.messages = false
2025-10-23T10:06:23.099522519Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.099524128Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.099525878Z 	errors.tolerance = none
2025-10-23T10:06:23.099527453Z 	exactly.once.support = requested
2025-10-23T10:06:23.099529116Z 	header.converter = null
2025-10-23T10:06:23.099530670Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.099532292Z 	key.converter = null
2025-10-23T10:06:23.099533865Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.099535449Z 	name = pg-connector
2025-10-23T10:06:23.099537089Z 	offsets.storage.topic = null
2025-10-23T10:06:23.099538653Z 	predicates = []
2025-10-23T10:06:23.099540302Z 	tasks.max = 1
2025-10-23T10:06:23.099542003Z 	tasks.max.enforce = true
2025-10-23T10:06:23.099543534Z 	topic.creation.groups = []
2025-10-23T10:06:23.099545373Z 	transaction.boundary = poll
2025-10-23T10:06:23.099546982Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.099548608Z 	transforms = []
2025-10-23T10:06:23.099550227Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.099561017Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.099563097Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.099625828Z 2025-10-23T10:06:23,099 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T10:06:23.099631191Z 	config.action.reload = restart
2025-10-23T10:06:23.099633141Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.099634983Z 	connector.plugin.version = null
2025-10-23T10:06:23.099636632Z 	errors.log.enable = false
2025-10-23T10:06:23.099638416Z 	errors.log.include.messages = false
2025-10-23T10:06:23.099640016Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.099641733Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.099643307Z 	errors.tolerance = none
2025-10-23T10:06:23.099644882Z 	exactly.once.support = requested
2025-10-23T10:06:23.099646459Z 	header.converter = null
2025-10-23T10:06:23.099648116Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.099649720Z 	key.converter = null
2025-10-23T10:06:23.099653613Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.099655555Z 	name = pg-connector
2025-10-23T10:06:23.099657215Z 	offsets.storage.topic = null
2025-10-23T10:06:23.099658852Z 	predicates = []
2025-10-23T10:06:23.099660413Z 	tasks.max = 1
2025-10-23T10:06:23.099662011Z 	tasks.max.enforce = true
2025-10-23T10:06:23.099663576Z 	topic.creation.groups = []
2025-10-23T10:06:23.099665156Z 	transaction.boundary = poll
2025-10-23T10:06:23.099666736Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.099668343Z 	transforms = []
2025-10-23T10:06:23.099669952Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.099671703Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.099673341Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.114654221Z 2025-10-23T10:06:23,114 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Tasks [pg-connector-0] configs updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.116049756Z 2025-10-23T10:06:23,115 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.116097209Z 2025-10-23T10:06:23,116 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.117737705Z 2025-10-23T10:06:23,117 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully joined group with generation Generation{generationId=17, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.119720877Z 2025-10-23T10:06:23,119 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Successfully synced group in generation Generation{generationId=17, memberId='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2025-10-23T10:06:23.119863507Z 2025-10-23T10:06:23,119 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Joined group at generation 17 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-172.17.0.4:8083-b3f6561e-1628-4bba-b3a0-6738824f3e7a', leaderUrl='http://172.17.0.4:8083/', offset=108, connectorIds=[pg-connector], taskIds=[pg-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.120000157Z 2025-10-23T10:06:23,119 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting connectors and tasks using config offset 108   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.120136979Z 2025-10-23T10:06:23,120 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Starting task pg-connector-0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.120337035Z 2025-10-23T10:06:23,120 INFO   ||  Creating task pg-connector-0   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.120830714Z 2025-10-23T10:06:23,120 INFO   ||  ConnectorConfig values: 
2025-10-23T10:06:23.120842151Z 	config.action.reload = restart
2025-10-23T10:06:23.120845353Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.120847973Z 	connector.plugin.version = null
2025-10-23T10:06:23.120850047Z 	errors.log.enable = false
2025-10-23T10:06:23.120852009Z 	errors.log.include.messages = false
2025-10-23T10:06:23.120854124Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.120856093Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.120858425Z 	errors.tolerance = none
2025-10-23T10:06:23.120860336Z 	header.converter = null
2025-10-23T10:06:23.120862231Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.120864223Z 	key.converter = null
2025-10-23T10:06:23.120866143Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.120868099Z 	name = pg-connector
2025-10-23T10:06:23.120870029Z 	predicates = []
2025-10-23T10:06:23.120872112Z 	tasks.max = 1
2025-10-23T10:06:23.120874172Z 	tasks.max.enforce = true
2025-10-23T10:06:23.120876429Z 	transforms = []
2025-10-23T10:06:23.120878396Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.120880550Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.120885789Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.120942032Z 2025-10-23T10:06:23,120 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T10:06:23.120957446Z 	config.action.reload = restart
2025-10-23T10:06:23.120961208Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.120963799Z 	connector.plugin.version = null
2025-10-23T10:06:23.120966651Z 	errors.log.enable = false
2025-10-23T10:06:23.120969293Z 	errors.log.include.messages = false
2025-10-23T10:06:23.120971701Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.120974136Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.120976175Z 	errors.tolerance = none
2025-10-23T10:06:23.120978187Z 	header.converter = null
2025-10-23T10:06:23.120980154Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.120982220Z 	key.converter = null
2025-10-23T10:06:23.120984332Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.120986385Z 	name = pg-connector
2025-10-23T10:06:23.120988333Z 	predicates = []
2025-10-23T10:06:23.120990328Z 	tasks.max = 1
2025-10-23T10:06:23.120992669Z 	tasks.max.enforce = true
2025-10-23T10:06:23.120994818Z 	transforms = []
2025-10-23T10:06:23.120996823Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.120999120Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.121001251Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.121009357Z 2025-10-23T10:06:23,120 INFO   ||  TaskConfig values: 
2025-10-23T10:06:23.121012072Z 	task.class = class io.debezium.connector.postgresql.PostgresConnectorTask
2025-10-23T10:06:23.121014290Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.121521146Z 2025-10-23T10:06:23,121 INFO   ||  Instantiated task pg-connector-0 with version 3.3.1.Final of type io.debezium.connector.postgresql.PostgresConnectorTask   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.121686853Z 2025-10-23T10:06:23,121 INFO   ||  JsonConverterConfig values: 
2025-10-23T10:06:23.121694123Z 	converter.type = value
2025-10-23T10:06:23.121696991Z 	decimal.format = BASE64
2025-10-23T10:06:23.121699326Z 	replace.null.with.default = true
2025-10-23T10:06:23.121701500Z 	schemas.cache.size = 1000
2025-10-23T10:06:23.121703650Z 	schemas.enable = false
2025-10-23T10:06:23.121705843Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.121766008Z 2025-10-23T10:06:23,121 INFO   ||  JsonConverterConfig values: 
2025-10-23T10:06:23.121772615Z 	converter.type = key
2025-10-23T10:06:23.121775414Z 	decimal.format = BASE64
2025-10-23T10:06:23.121785713Z 	replace.null.with.default = true
2025-10-23T10:06:23.121788541Z 	schemas.cache.size = 1000
2025-10-23T10:06:23.121790823Z 	schemas.enable = true
2025-10-23T10:06:23.121792968Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.121797942Z 2025-10-23T10:06:23,121 INFO   ||  Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task pg-connector-0 using the worker config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.121900063Z 2025-10-23T10:06:23,121 INFO   ||  Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task pg-connector-0 using the connector config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.121912774Z 2025-10-23T10:06:23,121 INFO   ||  Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task pg-connector-0 using the worker config   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.122127065Z 2025-10-23T10:06:23,122 INFO   ||  Initializing: org.apache.kafka.connect.runtime.TransformationChain{}   [org.apache.kafka.connect.runtime.Worker]
2025-10-23T10:06:23.122501326Z 2025-10-23T10:06:23,122 INFO   ||  SourceConnectorConfig values: 
2025-10-23T10:06:23.122511133Z 	config.action.reload = restart
2025-10-23T10:06:23.122513979Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.122516334Z 	connector.plugin.version = null
2025-10-23T10:06:23.122518656Z 	errors.log.enable = false
2025-10-23T10:06:23.122520709Z 	errors.log.include.messages = false
2025-10-23T10:06:23.122522749Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.122524785Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.122526787Z 	errors.tolerance = none
2025-10-23T10:06:23.122528751Z 	exactly.once.support = requested
2025-10-23T10:06:23.122531162Z 	header.converter = null
2025-10-23T10:06:23.122533146Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.122535266Z 	key.converter = null
2025-10-23T10:06:23.122537238Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.122539250Z 	name = pg-connector
2025-10-23T10:06:23.122541319Z 	offsets.storage.topic = null
2025-10-23T10:06:23.122543350Z 	predicates = []
2025-10-23T10:06:23.122545287Z 	tasks.max = 1
2025-10-23T10:06:23.122547245Z 	tasks.max.enforce = true
2025-10-23T10:06:23.122549198Z 	topic.creation.groups = []
2025-10-23T10:06:23.122551198Z 	transaction.boundary = poll
2025-10-23T10:06:23.122553203Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.122555218Z 	transforms = []
2025-10-23T10:06:23.122557158Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.122574438Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.122577103Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.122627746Z 2025-10-23T10:06:23,122 INFO   ||  EnrichedConnectorConfig values: 
2025-10-23T10:06:23.122631902Z 	config.action.reload = restart
2025-10-23T10:06:23.122634253Z 	connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.122640500Z 	connector.plugin.version = null
2025-10-23T10:06:23.122643034Z 	errors.log.enable = false
2025-10-23T10:06:23.122645157Z 	errors.log.include.messages = false
2025-10-23T10:06:23.122647308Z 	errors.retry.delay.max.ms = 60000
2025-10-23T10:06:23.122649360Z 	errors.retry.timeout = 0
2025-10-23T10:06:23.122651441Z 	errors.tolerance = none
2025-10-23T10:06:23.122653707Z 	exactly.once.support = requested
2025-10-23T10:06:23.122656030Z 	header.converter = null
2025-10-23T10:06:23.122658205Z 	header.converter.plugin.version = null
2025-10-23T10:06:23.122660423Z 	key.converter = null
2025-10-23T10:06:23.122662734Z 	key.converter.plugin.version = null
2025-10-23T10:06:23.122664763Z 	name = pg-connector
2025-10-23T10:06:23.122666680Z 	offsets.storage.topic = null
2025-10-23T10:06:23.122668643Z 	predicates = []
2025-10-23T10:06:23.122671568Z 	tasks.max = 1
2025-10-23T10:06:23.122673593Z 	tasks.max.enforce = true
2025-10-23T10:06:23.122675709Z 	topic.creation.groups = []
2025-10-23T10:06:23.122677715Z 	transaction.boundary = poll
2025-10-23T10:06:23.122679785Z 	transaction.boundary.interval.ms = null
2025-10-23T10:06:23.122681970Z 	transforms = []
2025-10-23T10:06:23.122683967Z 	value.converter = class org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.122686125Z 	value.converter.plugin.version = null
2025-10-23T10:06:23.122688397Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.123055724Z 2025-10-23T10:06:23,122 INFO   ||  ProducerConfig values: 
2025-10-23T10:06:23.123066217Z 	acks = -1
2025-10-23T10:06:23.123069077Z 	batch.size = 16384
2025-10-23T10:06:23.123071358Z 	bootstrap.servers = [kafka:29092]
2025-10-23T10:06:23.123073537Z 	buffer.memory = 134217728
2025-10-23T10:06:23.123075613Z 	client.dns.lookup = use_all_dns_ips
2025-10-23T10:06:23.123077813Z 	client.id = connector-producer-pg-connector-0
2025-10-23T10:06:23.123093777Z 	compression.gzip.level = -1
2025-10-23T10:06:23.123096482Z 	compression.lz4.level = 9
2025-10-23T10:06:23.123098872Z 	compression.type = none
2025-10-23T10:06:23.123109917Z 	compression.zstd.level = 3
2025-10-23T10:06:23.123112691Z 	connections.max.idle.ms = 540000
2025-10-23T10:06:23.123115089Z 	delivery.timeout.ms = 2147483647
2025-10-23T10:06:23.123117178Z 	enable.idempotence = false
2025-10-23T10:06:23.123119497Z 	enable.metrics.push = true
2025-10-23T10:06:23.123121730Z 	interceptor.classes = []
2025-10-23T10:06:23.123124090Z 	key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2025-10-23T10:06:23.123126374Z 	linger.ms = 5
2025-10-23T10:06:23.123128816Z 	max.block.ms = 9223372036854775807
2025-10-23T10:06:23.123131189Z 	max.in.flight.requests.per.connection = 1
2025-10-23T10:06:23.123133256Z 	max.request.size = 159977748
2025-10-23T10:06:23.123135397Z 	metadata.max.age.ms = 300000
2025-10-23T10:06:23.123137486Z 	metadata.max.idle.ms = 300000
2025-10-23T10:06:23.123139579Z 	metadata.recovery.rebootstrap.trigger.ms = 300000
2025-10-23T10:06:23.123141834Z 	metadata.recovery.strategy = rebootstrap
2025-10-23T10:06:23.123143944Z 	metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
2025-10-23T10:06:23.123146058Z 	metrics.num.samples = 2
2025-10-23T10:06:23.123148090Z 	metrics.recording.level = INFO
2025-10-23T10:06:23.123150259Z 	metrics.sample.window.ms = 30000
2025-10-23T10:06:23.123152453Z 	partitioner.adaptive.partitioning.enable = true
2025-10-23T10:06:23.123154820Z 	partitioner.availability.timeout.ms = 0
2025-10-23T10:06:23.123157048Z 	partitioner.class = null
2025-10-23T10:06:23.123159095Z 	partitioner.ignore.keys = false
2025-10-23T10:06:23.123161096Z 	receive.buffer.bytes = 32768
2025-10-23T10:06:23.123163097Z 	reconnect.backoff.max.ms = 1000
2025-10-23T10:06:23.123165082Z 	reconnect.backoff.ms = 50
2025-10-23T10:06:23.123167017Z 	request.timeout.ms = 30000
2025-10-23T10:06:23.123169206Z 	retries = 2147483647
2025-10-23T10:06:23.123171367Z 	retry.backoff.max.ms = 1000
2025-10-23T10:06:23.123173475Z 	retry.backoff.ms = 100
2025-10-23T10:06:23.123175553Z 	sasl.client.callback.handler.class = null
2025-10-23T10:06:23.123177605Z 	sasl.jaas.config = null
2025-10-23T10:06:23.123179613Z 	sasl.kerberos.kinit.cmd = /usr/bin/kinit
2025-10-23T10:06:23.123181716Z 	sasl.kerberos.min.time.before.relogin = 60000
2025-10-23T10:06:23.123183913Z 	sasl.kerberos.service.name = null
2025-10-23T10:06:23.123185932Z 	sasl.kerberos.ticket.renew.jitter = 0.05
2025-10-23T10:06:23.123187975Z 	sasl.kerberos.ticket.renew.window.factor = 0.8
2025-10-23T10:06:23.123193025Z 	sasl.login.callback.handler.class = null
2025-10-23T10:06:23.123195647Z 	sasl.login.class = null
2025-10-23T10:06:23.123197784Z 	sasl.login.connect.timeout.ms = null
2025-10-23T10:06:23.123199840Z 	sasl.login.read.timeout.ms = null
2025-10-23T10:06:23.123202097Z 	sasl.login.refresh.buffer.seconds = 300
2025-10-23T10:06:23.123204238Z 	sasl.login.refresh.min.period.seconds = 60
2025-10-23T10:06:23.123206385Z 	sasl.login.refresh.window.factor = 0.8
2025-10-23T10:06:23.123208481Z 	sasl.login.refresh.window.jitter = 0.05
2025-10-23T10:06:23.123210590Z 	sasl.login.retry.backoff.max.ms = 10000
2025-10-23T10:06:23.123213050Z 	sasl.login.retry.backoff.ms = 100
2025-10-23T10:06:23.123215221Z 	sasl.mechanism = GSSAPI
2025-10-23T10:06:23.123218392Z 	sasl.oauthbearer.assertion.algorithm = RS256
2025-10-23T10:06:23.123220722Z 	sasl.oauthbearer.assertion.claim.aud = null
2025-10-23T10:06:23.123223095Z 	sasl.oauthbearer.assertion.claim.exp.seconds = 300
2025-10-23T10:06:23.123225444Z 	sasl.oauthbearer.assertion.claim.iss = null
2025-10-23T10:06:23.123227622Z 	sasl.oauthbearer.assertion.claim.jti.include = false
2025-10-23T10:06:23.123229869Z 	sasl.oauthbearer.assertion.claim.nbf.seconds = 60
2025-10-23T10:06:23.123231986Z 	sasl.oauthbearer.assertion.claim.sub = null
2025-10-23T10:06:23.123234040Z 	sasl.oauthbearer.assertion.file = null
2025-10-23T10:06:23.123236194Z 	sasl.oauthbearer.assertion.private.key.file = null
2025-10-23T10:06:23.123238341Z 	sasl.oauthbearer.assertion.private.key.passphrase = null
2025-10-23T10:06:23.123240497Z 	sasl.oauthbearer.assertion.template.file = null
2025-10-23T10:06:23.123242586Z 	sasl.oauthbearer.client.credentials.client.id = null
2025-10-23T10:06:23.123244930Z 	sasl.oauthbearer.client.credentials.client.secret = null
2025-10-23T10:06:23.123247326Z 	sasl.oauthbearer.clock.skew.seconds = 30
2025-10-23T10:06:23.123249370Z 	sasl.oauthbearer.expected.audience = null
2025-10-23T10:06:23.123251487Z 	sasl.oauthbearer.expected.issuer = null
2025-10-23T10:06:23.123253676Z 	sasl.oauthbearer.header.urlencode = false
2025-10-23T10:06:23.123255864Z 	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2025-10-23T10:06:23.123258065Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2025-10-23T10:06:23.123260710Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2025-10-23T10:06:23.123262882Z 	sasl.oauthbearer.jwks.endpoint.url = null
2025-10-23T10:06:23.123264986Z 	sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
2025-10-23T10:06:23.123267230Z 	sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
2025-10-23T10:06:23.123272838Z 	sasl.oauthbearer.scope = null
2025-10-23T10:06:23.123275254Z 	sasl.oauthbearer.scope.claim.name = scope
2025-10-23T10:06:23.123277708Z 	sasl.oauthbearer.sub.claim.name = sub
2025-10-23T10:06:23.123279762Z 	sasl.oauthbearer.token.endpoint.url = null
2025-10-23T10:06:23.123282900Z 	security.protocol = PLAINTEXT
2025-10-23T10:06:23.123285208Z 	security.providers = null
2025-10-23T10:06:23.123287522Z 	send.buffer.bytes = 131072
2025-10-23T10:06:23.123289559Z 	socket.connection.setup.timeout.max.ms = 30000
2025-10-23T10:06:23.123291652Z 	socket.connection.setup.timeout.ms = 10000
2025-10-23T10:06:23.123293682Z 	ssl.cipher.suites = null
2025-10-23T10:06:23.123295846Z 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2025-10-23T10:06:23.123298062Z 	ssl.endpoint.identification.algorithm = https
2025-10-23T10:06:23.123310020Z 	ssl.engine.factory.class = null
2025-10-23T10:06:23.123312433Z 	ssl.key.password = null
2025-10-23T10:06:23.123314598Z 	ssl.keymanager.algorithm = SunX509
2025-10-23T10:06:23.123316713Z 	ssl.keystore.certificate.chain = null
2025-10-23T10:06:23.123318781Z 	ssl.keystore.key = null
2025-10-23T10:06:23.123320890Z 	ssl.keystore.location = null
2025-10-23T10:06:23.123323081Z 	ssl.keystore.password = null
2025-10-23T10:06:23.123325116Z 	ssl.keystore.type = JKS
2025-10-23T10:06:23.123327132Z 	ssl.protocol = TLSv1.3
2025-10-23T10:06:23.123329154Z 	ssl.provider = null
2025-10-23T10:06:23.123331209Z 	ssl.secure.random.implementation = null
2025-10-23T10:06:23.123334050Z 	ssl.trustmanager.algorithm = PKIX
2025-10-23T10:06:23.123336469Z 	ssl.truststore.certificates = null
2025-10-23T10:06:23.123338707Z 	ssl.truststore.location = null
2025-10-23T10:06:23.123340835Z 	ssl.truststore.password = null
2025-10-23T10:06:23.123342898Z 	ssl.truststore.type = JKS
2025-10-23T10:06:23.123344934Z 	transaction.timeout.ms = 60000
2025-10-23T10:06:23.123347075Z 	transaction.two.phase.commit.enable = false
2025-10-23T10:06:23.123349301Z 	transactional.id = null
2025-10-23T10:06:23.123351330Z 	value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2025-10-23T10:06:23.123353628Z    [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.123358946Z 2025-10-23T10:06:23,123 INFO   ||  initializing Kafka metrics collector   [org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector]
2025-10-23T10:06:23.125931016Z 2025-10-23T10:06:23,125 INFO   ||  These configurations '[metrics.context.connect.group.id, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet.   [org.apache.kafka.common.config.AbstractConfig]
2025-10-23T10:06:23.126002663Z 2025-10-23T10:06:23,125 INFO   ||  Kafka version: 4.1.0   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T10:06:23.126013724Z 2025-10-23T10:06:23,125 INFO   ||  Kafka commitId: 13f70256db3c994c   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T10:06:23.126016559Z 2025-10-23T10:06:23,125 INFO   ||  Kafka startTimeMs: 1761213983125   [org.apache.kafka.common.utils.AppInfoParser]
2025-10-23T10:06:23.127027146Z 2025-10-23T10:06:23,126 INFO   ||  [Worker clientId=connect-172.17.0.4:8083, groupId=debezium] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2025-10-23T10:06:23.127116114Z 2025-10-23T10:06:23,127 INFO   ||  You are using a no-op lineage emitter. If you want to emit open lineage event, please set 'openlineage.integration.enabled=true'   [io.debezium.openlineage.emitter.NoOpLineageEmitter]
2025-10-23T10:06:23.127821249Z 2025-10-23T10:06:23,127 INFO   ||  Starting PostgresConnectorTask with configuration:
2025-10-23T10:06:23.127834533Z    connector.class = io.debezium.connector.postgresql.PostgresConnector
2025-10-23T10:06:23.127837410Z    database.user = postgres
2025-10-23T10:06:23.127839749Z    database.dbname = postgres
2025-10-23T10:06:23.127842083Z    slot.name = dbname_debezium
2025-10-23T10:06:23.127844520Z    publication.name = dbname_publication
2025-10-23T10:06:23.127846613Z    database.server.name = pg-dev
2025-10-23T10:06:23.127848653Z    heartbeat.interval.ms = 5000
2025-10-23T10:06:23.127850895Z    buffer.memory = 259977748
2025-10-23T10:06:23.127852908Z    plugin.name = pgoutput
2025-10-23T10:06:23.127854859Z    database.port = 5432
2025-10-23T10:06:23.127856779Z    max.request.size = 159977748
2025-10-23T10:06:23.127858710Z    topic.prefix = pg-dev
2025-10-23T10:06:23.127860703Z    task.class = io.debezium.connector.postgresql.PostgresConnectorTask
2025-10-23T10:06:23.127862769Z    database.hostname = postgres
2025-10-23T10:06:23.127864752Z    database.password = ********
2025-10-23T10:06:23.127866734Z    value.converter.schemas.enable = false
2025-10-23T10:06:23.127868873Z    name = pg-connector
2025-10-23T10:06:23.127870850Z    table.include.list = public.(.*)
2025-10-23T10:06:23.127872871Z    value.converter = org.apache.kafka.connect.json.JsonConverter
2025-10-23T10:06:23.127874935Z    snapshot.mode = no_data
2025-10-23T10:06:23.127876918Z    [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:06:23.127973628Z 2025-10-23T10:06:23,127 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2025-10-23T10:06:23.128527991Z 2025-10-23T10:06:23,128 INFO   ||  [Producer clientId=connector-producer-pg-connector-0] Cluster ID: 3aWVlgGFSqefKV6stX0huQ   [org.apache.kafka.clients.Metadata]
2025-10-23T10:06:23.128564598Z 2025-10-23T10:06:23,128 INFO   ||  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2025-10-23T10:06:23.134839614Z 2025-10-23T10:06:23,134 INFO   ||  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.134875003Z 2025-10-23T10:06:23,134 INFO   ||  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.135339438Z 2025-10-23T10:06:23,135 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T10:06:23.149174081Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:13552, name:_pg_user_mappings] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149197929Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:16405, name:bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149204302Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:16404, name:_bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149206912Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:16414, name:foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149235651Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:16413, name:_foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149620891Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:26493, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149631605Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:26492, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149786474Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35182, name:dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149835935Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35181, name:_dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149849929Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35283, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149926598Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35282, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149934563Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35396, name:db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149936418Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35395, name:_db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149963349Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35401, name:db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.149991786Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35400, name:_db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150005531Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35404, name:async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150027306Z 2025-10-23T10:06:23,149 WARN   ||  Type [oid:35403, name:_async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150036495Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35409, name:async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150055606Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35408, name:_async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150059802Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35414, name:async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150100674Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35413, name:_async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150109520Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35419, name:async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150174625Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35418, name:_async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150218104Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35424, name:async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150226236Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35423, name:_async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150229110Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35427, name:async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150245065Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35426, name:_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150254079Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35432, name:async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150257872Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35431, name:_async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150262479Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35437, name:async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150265469Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35436, name:_async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150268625Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35442, name:async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150302884Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35441, name:_async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150307570Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35445, name:temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150339022Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35444, name:_temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150341456Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35448, name:async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150356386Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35447, name:_async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150358283Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35451, name:ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150371216Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35450, name:_ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150372901Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35456, name:temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150382385Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:35455, name:_temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150410039Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:46622, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150414394Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:46621, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150418712Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:63085, name:debezium_bug_example] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150424746Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:63084, name:_debezium_bug_example] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150454990Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:13226, name:cardinal_number] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150460200Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:13229, name:character_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150468979Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:13231, name:sql_identifier] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150475513Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:13237, name:time_stamp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.150481579Z 2025-10-23T10:06:23,150 WARN   ||  Type [oid:13239, name:yes_or_no] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.153581495Z 2025-10-23T10:06:23,153 INFO   ||  Found previous partition offset PostgresPartition [sourcePartition={server=pg-dev}]: {lsn_proc=49928520864, messageType=COMMIT, lsn_commit=49928520864, lsn=49928520864, txId=260750, ts_usec=1761212863131177}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:06:23.166746837Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:13552, name:_pg_user_mappings] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.166777047Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:16405, name:bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.166779884Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:16404, name:_bar] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.166781730Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:16414, name:foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.166783548Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:16413, name:_foo] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.166998569Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:26493, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167007325Z 2025-10-23T10:06:23,166 WARN   ||  Type [oid:26492, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167110377Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35182, name:dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167116566Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35181, name:_dictionary_update_event] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167159710Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35283, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167163309Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35282, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167189898Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35396, name:db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167197951Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35395, name:_db_changelog_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167200831Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35401, name:db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167203128Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35400, name:_db_changelog_async_tasklock] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167205175Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35404, name:async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167208945Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35403, name:_async_task_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167218263Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35409, name:async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167220986Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35408, name:_async_task_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167227746Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35414, name:async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167237382Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35413, name:_async_operation_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167245114Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35419, name:async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167247837Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35418, name:_async_operation_state] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167250014Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35424, name:async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167256869Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35423, name:_async_operation] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167259369Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35427, name:async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167337671Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35426, name:_async_task] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167342473Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35432, name:async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167345143Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35431, name:_async_task_error_type] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167347340Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35437, name:async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167349519Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35436, name:_async_task_error] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167351780Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35442, name:async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167353871Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35441, name:_async_task_retry_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167355932Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35445, name:temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167359536Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35444, name:_temporary_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167361682Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35448, name:async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167363643Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35447, name:_async_task_delete_policy] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167373107Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35451, name:ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167377206Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35450, name:_ordered_action] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167392481Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35456, name:temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167395515Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:35455, name:_temporary_text_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167397664Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:46622, name:f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167403241Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:46621, name:_f_ch_one_sided_result_temp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167410311Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:63085, name:debezium_bug_example] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167412702Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:63084, name:_debezium_bug_example] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167431116Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:13226, name:cardinal_number] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167433935Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:13229, name:character_data] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167439447Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:13231, name:sql_identifier] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167445097Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:13237, name:time_stamp] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.167450807Z 2025-10-23T10:06:23,167 WARN   ||  Type [oid:13239, name:yes_or_no] is already mapped   [io.debezium.connector.postgresql.TypeRegistry]
2025-10-23T10:06:23.168912117Z 2025-10-23T10:06:23,168 INFO   ||  Guardrail validation skipped   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T10:06:23.170027460Z 2025-10-23T10:06:23,169 INFO   ||  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF8C4A0}, catalogXmin=260749]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T10:06:23.170042146Z 2025-10-23T10:06:23,169 INFO   ||  Slot 'dbname_debezium' has restart LSN 'LSN{B/9FF85CE0}'   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T10:06:23.170198348Z 2025-10-23T10:06:23,170 INFO   Postgres||postgres-connector-task  Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='pg-dev'db='postgres', lsn=LSN{B/9FF8C4A0}, txId=260750, messageType=COMMIT, lastCommitLsn=LSN{B/9FF8C4A0}, timestamp=2025-10-23T09:47:43.131177Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{B/9FF8C4A0}, lastCommitLsn=LSN{B/9FF8C4A0}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T10:06:23.170940105Z 2025-10-23T10:06:23,170 INFO   Postgres||postgres-connector-task  user 'postgres' connected to database 'postgres' on PostgreSQL 16.5 (Debian 16.5-1.pgdg120+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 12.2.0-14) 12.2.0, 64-bit with roles:
2025-10-23T10:06:23.170959984Z 	role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170963065Z 	role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170965287Z 	role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170967212Z 	role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170969224Z 	role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170971365Z 	role 'pg_use_reserved_connections' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170973209Z 	role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170975040Z 	role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170977068Z 	role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170978947Z 	role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170980816Z 	role 'pg_create_subscription' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170982621Z 	role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170985015Z 	role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170987105Z 	role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2025-10-23T10:06:23.170989095Z 	role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2025-10-23T10:06:23.171211996Z 2025-10-23T10:06:23,171 INFO   Postgres||postgres-connector-task  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF8C4A0}, catalogXmin=260749]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T10:06:23.171986358Z 2025-10-23T10:06:23,171 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = SignalProcessor   [io.debezium.util.Threads]
2025-10-23T10:06:23.172196065Z 2025-10-23T10:06:23,172 INFO   Postgres||postgres-connector-task  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2025-10-23T10:06:23.172496331Z 2025-10-23T10:06:23,172 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = change-event-source-coordinator   [io.debezium.util.Threads]
2025-10-23T10:06:23.172526873Z 2025-10-23T10:06:23,172 INFO   Postgres||postgres-connector-task  Requested thread factory for component PostgresConnector, id = pg-dev named = blocking-snapshot   [io.debezium.util.Threads]
2025-10-23T10:06:23.172624071Z 2025-10-23T10:06:23,172 INFO   Postgres||postgres-connector-task  Creating thread debezium-postgresconnector-pg-dev-change-event-source-coordinator   [io.debezium.util.Threads]
2025-10-23T10:06:23.172811882Z 2025-10-23T10:06:23,172 INFO   ||  WorkerSourceTask{id=pg-connector-0} Source task finished initialization and start   [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask]
2025-10-23T10:06:23.173233240Z 2025-10-23T10:06:23,173 INFO   Postgres||snapshot  Metrics registered   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T10:06:23.173260002Z 2025-10-23T10:06:23,173 INFO   Postgres||snapshot  Context created   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T10:06:23.173350480Z 2025-10-23T10:06:23,173 INFO   Postgres||snapshot  A previous offset indicating a completed snapshot has been found.   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2025-10-23T10:06:23.173359910Z 2025-10-23T10:06:23,173 INFO   Postgres||snapshot  According to the connector configuration no snapshot will be executed   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2025-10-23T10:06:23.173624712Z 2025-10-23T10:06:23,173 INFO   Postgres||snapshot  Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='pg-dev'db='postgres', lsn=LSN{B/9FF8C4A0}, txId=260750, messageType=COMMIT, lastCommitLsn=LSN{B/9FF8C4A0}, timestamp=2025-10-23T09:47:43.131177Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{B/9FF8C4A0}, lastCommitLsn=LSN{B/9FF8C4A0}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T10:06:23.173771645Z 2025-10-23T10:06:23,173 INFO   Postgres||streaming  Requested thread factory for component PostgresStreamingChangeEventSource, id = pg-dev named = lsn-flush   [io.debezium.util.Threads]
2025-10-23T10:06:23.173827626Z 2025-10-23T10:06:23,173 INFO   Postgres||streaming  Connected metrics set to 'true'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T10:06:23.192655701Z 2025-10-23T10:06:23,192 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.debezium_bug_example' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T10:06:23.192845388Z 2025-10-23T10:06:23,192 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.bar' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T10:06:23.192989226Z 2025-10-23T10:06:23,192 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.with_default' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T10:06:23.193150836Z 2025-10-23T10:06:23,193 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.foo' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T10:06:23.193323404Z 2025-10-23T10:06:23,193 INFO   Postgres||streaming  REPLICA IDENTITY for 'public.f_ch_one_sided_result_temp' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2025-10-23T10:06:23.195220674Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  SignalProcessor started. Scheduling it every 5000ms   [io.debezium.pipeline.signal.SignalProcessor]
2025-10-23T10:06:23.195256452Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-SignalProcessor   [io.debezium.util.Threads]
2025-10-23T10:06:23.195402697Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  Starting streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2025-10-23T10:06:23.195453533Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  Retrieved latest position from stored offset 'LSN{B/9FF8C4A0}'   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T10:06:23.195474075Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  Looking for WAL restart position for last commit LSN 'LSN{B/9FF8C4A0}' and last change LSN 'LSN{B/9FF8C4A0}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T10:06:23.195530849Z 2025-10-23T10:06:23,195 INFO   Postgres||streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T10:06:23.208542337Z 2025-10-23T10:06:23,208 INFO   Postgres||streaming  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{B/9FF8C4A0}, catalogXmin=260749]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2025-10-23T10:06:23.208639210Z 2025-10-23T10:06:23,208 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.208647084Z 2025-10-23T10:06:23,208 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.209122504Z 2025-10-23T10:06:23,208 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T10:06:23.220319623Z 2025-10-23T10:06:23,220 INFO   Postgres||streaming  Requested thread factory for component PostgresConnector, id = pg-dev named = keep-alive   [io.debezium.util.Threads]
2025-10-23T10:06:23.220349203Z 2025-10-23T10:06:23,220 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-keep-alive   [io.debezium.util.Threads]
2025-10-23T10:06:23.220748350Z 2025-10-23T10:06:23,220 INFO   Postgres||streaming  Searching for WAL resume position   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T10:06:23.220902710Z 2025-10-23T10:06:23,220 INFO   Postgres||streaming  First LSN 'LSN{B/9FFBD6E8}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T10:06:23.224771763Z 2025-10-23T10:06:23,224 INFO   Postgres||streaming  Received COMMIT LSN 'LSN{B/9FFBD7F8}' larger than than last stored commit LSN 'LSN{B/9FF8C4A0}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T10:06:23.224792148Z 2025-10-23T10:06:23,224 INFO   Postgres||streaming  Will restart from LSN 'LSN{B/9FFBD6E8}' that is start of the first unprocessed transaction   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T10:06:23.224829066Z 2025-10-23T10:06:23,224 INFO   Postgres||streaming  WAL resume position 'LSN{B/9FFBD6E8}' discovered   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T10:06:23.225320220Z 2025-10-23T10:06:23,225 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.225366128Z 2025-10-23T10:06:23,225 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.225432224Z 2025-10-23T10:06:23,225 ERROR  ||  Unexpected exception while performing keepalive status update on the replication stream   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T10:06:23.225476864Z java.lang.InterruptedException: sleep interrupted
2025-10-23T10:06:23.225480678Z 	at java.base/java.lang.Thread.sleep0(Native Method) ~[?:?]
2025-10-23T10:06:23.225483127Z 	at java.base/java.lang.Thread.sleep(Thread.java:509) [?:?]
2025-10-23T10:06:23.225485082Z 	at io.debezium.util.Metronome$1.pause(Metronome.java:57) ~[debezium-core-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T10:06:23.225487535Z 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:1007) ~[debezium-connector-postgres-3.3.1.Final.jar:3.3.1.Final]
2025-10-23T10:06:23.225489769Z 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
2025-10-23T10:06:23.225491708Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
2025-10-23T10:06:23.225493599Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
2025-10-23T10:06:23.225495484Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
2025-10-23T10:06:23.225497381Z 	at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
2025-10-23T10:06:23.225831513Z 2025-10-23T10:06:23,225 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T10:06:23.225878161Z 2025-10-23T10:06:23,225 INFO   Postgres||streaming  Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.225938814Z 2025-10-23T10:06:23,225 INFO   Postgres||streaming  Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close   [io.debezium.util.Threads]
2025-10-23T10:06:23.226367873Z 2025-10-23T10:06:23,226 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2025-10-23T10:06:23.232546384Z 2025-10-23T10:06:23,232 INFO   Postgres||streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2025-10-23T10:06:23.244358001Z 2025-10-23T10:06:23,244 INFO   Postgres||streaming  Requested thread factory for component PostgresConnector, id = pg-dev named = keep-alive   [io.debezium.util.Threads]
2025-10-23T10:06:23.244386790Z 2025-10-23T10:06:23,244 INFO   Postgres||streaming  Creating thread debezium-postgresconnector-pg-dev-keep-alive   [io.debezium.util.Threads]
2025-10-23T10:06:23.244536982Z 2025-10-23T10:06:23,244 INFO   Postgres||streaming  Processing messages   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2025-10-23T10:06:23.244614338Z 2025-10-23T10:06:23,244 INFO   Postgres||streaming  Message with LSN 'LSN{B/9FFBD6E8}' arrived, switching off the filtering   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2025-10-23T10:06:23.763811683Z 2025-10-23T10:06:23,763 WARN   ||  [Producer clientId=connector-producer-pg-connector-0] The metadata response from the cluster reported a recoverable issue with correlation id 6 : {pg-dev.public.debezium_bug_example=LEADER_NOT_AVAILABLE}   [org.apache.kafka.clients.NetworkClient]
2025-10-23T10:06:28.386205526Z 2025-10-23T10:06:28,386 INFO   ||  2 records sent during previous 00:00:05.265, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:06:38.908632049Z 2025-10-23T10:06:38,908 INFO   ||  2 records sent during previous 00:00:10.522, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:06:58.957590217Z 2025-10-23T10:06:58,957 INFO   ||  4 records sent during previous 00:00:20.049, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:07:23.127234490Z 2025-10-23T10:07:23,127 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:07:23.508062830Z 2025-10-23T10:07:23,507 INFO   ||  Creating thread debezium-postgresstreamingchangeeventsource-pg-dev-lsn-flush   [io.debezium.util.Threads]
2025-10-23T10:07:39.540203397Z 2025-10-23T10:07:39,540 INFO   ||  8 records sent during previous 00:00:40.583, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:08:23.134579049Z 2025-10-23T10:08:23,134 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:09:00.202227113Z 2025-10-23T10:09:00,202 INFO   ||  16 records sent during previous 00:01:20.662, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:09:23.141102680Z 2025-10-23T10:09:23,140 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:10:23.148498512Z 2025-10-23T10:10:23,148 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:11:23.155598580Z 2025-10-23T10:11:23,155 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:11:42.029375082Z 2025-10-23T10:11:42,029 INFO   ||  32 records sent during previous 00:02:41.827, last recorded offset of {server=pg-dev} partition is {lsn_proc=49928722424, messageType=COMMIT, lsn_commit=49928722424, lsn=49928722424, txId=260755, ts_usec=1761213922423110}   [io.debezium.connector.common.BaseSourceTask]
2025-10-23T10:12:23.162310185Z 2025-10-23T10:12:23,162 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:13:23.168671994Z 2025-10-23T10:13:23,168 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 11 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:14:23.175159352Z 2025-10-23T10:14:23,174 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2025-10-23T10:15:23.182058706Z 2025-10-23T10:15:23,181 INFO   ||  WorkerSourceTask{id=pg-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]