[INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Engine started [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Engine started [INFO] io.debezium.embedded.EmbeddedEngine$EmbeddedConfig - EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 0 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /debezium_engine_wrapper/testing_config/state.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.discovery = hybrid_warn plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter [INFO] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium Validate Connection, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium Validate Connection, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium Validate Connection, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - executing 'SELECT version()' [INFO] io.debezium.connector.postgresql.PostgresConnector - Successfully tested connection for jdbc:postgresql://localhost:5432/postgres with user 'postgres' [TRACE] io.debezium.jdbc.JdbcConnection - running 'SHOW wal_level' [TRACE] io.debezium.jdbc.JdbcConnection - running 'SELECT r.rolcanlogin AS rolcanlogin, r.rolreplication AS rolreplication, CAST(array_position(ARRAY(SELECT b.rolname FROM pg_catalog.pg_auth_members m JOIN pg_catalog.pg_roles b ON (m.roleid = b.oid) WHERE m.member = r.oid), 'rds_superuser') AS BOOL) IS TRUE AS aws_superuser, CAST(array_position(ARRAY(SELECT b.rolname FROM pg_catalog.pg_auth_members m JOIN pg_catalog.pg_roles b ON (m.roleid = b.oid) WHERE m.member = r.oid), 'rdsadmin') AS BOOL) IS TRUE AS aws_admin, CAST(array_position(ARRAY(SELECT b.rolname FROM pg_catalog.pg_auth_members m JOIN pg_catalog.pg_roles b ON (m.roleid = b.oid) WHERE m.member = r.oid), 'rdsrepladmin') AS BOOL) IS TRUE AS aws_repladmin, CAST(array_position(ARRAY(SELECT b.rolname FROM pg_catalog.pg_auth_members m JOIN pg_catalog.pg_roles b ON (m.roleid = b.oid) WHERE m.member = r.oid), 'rds_replication') AS BOOL) IS TRUE AS aws_replication FROM pg_roles r WHERE r.rolname = current_user' [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [DEBUG] io.debezium.connector.common.BaseSourceTask - Setting task state to 'INITIAL', previous state was 'INITIAL' [INFO] io.debezium.connector.common.BaseSourceTask - Starting PostgresConnectorTask with configuration: [INFO] io.debezium.connector.common.BaseSourceTask - connector.class = io.debezium.connector.postgresql.PostgresConnector [INFO] io.debezium.connector.common.BaseSourceTask - transforms.unwrap.delete.handling.mode = rewrite [INFO] io.debezium.connector.common.BaseSourceTask - transforms = unwrap [INFO] io.debezium.connector.common.BaseSourceTask - schema.include.list = inventory [INFO] io.debezium.connector.common.BaseSourceTask - signal.enabled.channels = file,source [INFO] io.debezium.connector.common.BaseSourceTask - schema.history.internal.file.filename = /path/to/storage/schemahistory.dat [INFO] io.debezium.connector.common.BaseSourceTask - topic.prefix = testcdc [INFO] io.debezium.connector.common.BaseSourceTask - offset.storage.file.filename = /debezium_engine_wrapper/testing_config/state.dat [INFO] io.debezium.connector.common.BaseSourceTask - transforms.unwrap.drop.tombstones = true [INFO] io.debezium.connector.common.BaseSourceTask - signal.data.collection = inventory.debezium_signal [INFO] io.debezium.connector.common.BaseSourceTask - transforms.unwrap.type = keboola.cdc.debezium.transforms.ExtractNewRecordStateSchemaChanges [INFO] io.debezium.connector.common.BaseSourceTask - errors.retry.delay.initial.ms = 300 [INFO] io.debezium.connector.common.BaseSourceTask - value.converter = org.apache.kafka.connect.json.JsonConverter [INFO] io.debezium.connector.common.BaseSourceTask - key.converter = org.apache.kafka.connect.json.JsonConverter [INFO] io.debezium.connector.common.BaseSourceTask - publication.autocreate.mode = filtered [INFO] io.debezium.connector.common.BaseSourceTask - database.dbname = postgres [INFO] io.debezium.connector.common.BaseSourceTask - database.user = postgres [INFO] io.debezium.connector.common.BaseSourceTask - offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore [INFO] io.debezium.connector.common.BaseSourceTask - signal.file = /debezium_engine_wrapper/testing_config/signal-file.jsonl [INFO] io.debezium.connector.common.BaseSourceTask - offset.flush.timeout.ms = 5000 [INFO] io.debezium.connector.common.BaseSourceTask - errors.retry.delay.max.ms = 10000 [INFO] io.debezium.connector.common.BaseSourceTask - snapshot.max.threads = 1 [INFO] io.debezium.connector.common.BaseSourceTask - plugin.name = pgoutput [INFO] io.debezium.connector.common.BaseSourceTask - database.port = 5432 [INFO] io.debezium.connector.common.BaseSourceTask - offset.flush.interval.ms = 0 [INFO] io.debezium.connector.common.BaseSourceTask - schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory [INFO] io.debezium.connector.common.BaseSourceTask - transforms.unwrap.add.fields.prefix = kbc__ [INFO] io.debezium.connector.common.BaseSourceTask - errors.max.retries = -1 [INFO] io.debezium.connector.common.BaseSourceTask - database.hostname = localhost [INFO] io.debezium.connector.common.BaseSourceTask - database.password = ******** [INFO] io.debezium.connector.common.BaseSourceTask - name = kbc_cdc [INFO] io.debezium.connector.common.BaseSourceTask - transforms.unwrap.add.fields = __deleted:DELETED,source.ts_ms:event_timestamp [INFO] io.debezium.connector.common.BaseSourceTask - table.include.list = inventory.customers,inventory.orders,inventory.products [INFO] io.debezium.connector.common.BaseSourceTask - snapshot.mode = initial [INFO] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker [INFO] io.debezium.config.CommonConnectorConfig - Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium General, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium General, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13200' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13203' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13205' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13211' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13213' not cached, attempting to lookup from database. [INFO] io.debezium.connector.common.BaseSourceTask - Found previous partition offset PostgresPartition [sourcePartition={server=testcdc}]: {transaction_id=null, lsn_proc=34763432, messageType=DELETE, lsn_commit=34763376, lsn=34763376, txId=813, ts_usec=1706772607594584} [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium General, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13200' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13203' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13205' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13211' not cached, attempting to lookup from database. [TRACE] io.debezium.connector.postgresql.TypeRegistry - Type OID '13213' not cached, attempting to lookup from database. [TRACE] io.debezium.jdbc.JdbcConnection - running 'SELECT version(), current_user, current_database()' [TRACE] io.debezium.jdbc.JdbcConnection - running 'SELECT oid, rolname, rolsuper, rolinherit, rolcreaterole, rolcreatedb, rolcanlogin, rolreplication FROM pg_roles WHERE pg_has_role('postgres', oid, 'member')' [INFO] io.debezium.connector.postgresql.PostgresConnectorTask - user 'postgres' connected to database 'postgres' on PostgreSQL 15.2 (Debian 15.2-1.pgdg110+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 10.2.1-6) 10.2.1 20210110, 64-bit with roles: role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] [TRACE] io.debezium.jdbc.JdbcConnection - Inserting prepared statement 'select * from pg_replication_slots where slot_name = ? and database = ? and plugin = ?' removed from the cache [INFO] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/2127270}, catalogXmin=812] [INFO] io.debezium.connector.postgresql.PostgresConnectorTask - Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='testcdc'db='postgres', lsn=LSN{0/2127270}, txId=813, messageType=DELETE, lastCommitLsn=LSN{0/2127270}, timestamp=2024-02-01T07:30:07.594584Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/21272A8}, lastCommitLsn=LSN{0/2127270}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]] [INFO] io.debezium.util.Threads - Requested thread factory for connector PostgresConnector, id = testcdc named = SignalProcessor [INFO] io.debezium.pipeline.signal.channels.FileSignalChannel - Reading '/debezium_engine_wrapper/testing_config/signal-file.jsonl' file for signals [INFO] io.debezium.util.Threads - Requested thread factory for connector PostgresConnector, id = testcdc named = change-event-source-coordinator [INFO] io.debezium.util.Threads - Requested thread factory for connector PostgresConnector, id = testcdc named = blocking-snapshot [INFO] io.debezium.util.Threads - Creating thread debezium-postgresconnector-testcdc-change-event-source-coordinator [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Metrics registered [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Context created [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'schema-changes' using class 'io.debezium.pipeline.signal.actions.SchemaChanges' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'snapshot-window-open' using class 'io.debezium.pipeline.signal.actions.snapshotting.OpenIncrementalSnapshotWindow' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'execute-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'snapshot-window-close' using class 'io.debezium.pipeline.signal.actions.snapshotting.CloseIncrementalSnapshotWindow' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'log' using class 'io.debezium.pipeline.signal.actions.Log' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'stop-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.StopSnapshot' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'resume-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.ResumeIncrementalSnapshot' [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Registering signal 'pause-snapshot' using class 'io.debezium.pipeline.signal.actions.snapshotting.PauseIncrementalSnapshot' [INFO] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor started. Scheduling it every 5000ms [INFO] io.debezium.util.Threads - Creating thread debezium-postgresconnector-testcdc-SignalProcessor [TRACE] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor processing [DEBUG] io.debezium.connector.common.BaseSourceTask - Setting task state to 'RUNNING', previous state was 'INITIAL' [INFO] io.debezium.connector.postgresql.snapshot.InitialSnapshotter - Previous snapshot has completed successfully, streaming logical changes from last known position [INFO] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - According to the connector configuration no snapshot will be executed [TRACE] io.debezium.pipeline.signal.channels.SourceSignalChannel - Reading signaling events from queue [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Skipping snapshotting [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.pipeline.signal.channels.FileSignalChannel - Processing signal line: {"id":"d139b9b7-7777-4547-917d-11111111111", "type":"execute-snapshot", "data":{"type":"INCREMENTAL", "data-collections": ["inventory.products"]}} [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='testcdc'db='postgres', lsn=LSN{0/2127270}, txId=813, messageType=DELETE, lastCommitLsn=LSN{0/2127270}, timestamp=2024-02-01T07:30:07.594584Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/21272A8}, lastCommitLsn=LSN{0/2127270}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] [DEBUG] io.debezium.pipeline.ChangeEventSourceCoordinator - Snapshot result SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='testcdc'db='postgres', lsn=LSN{0/2127270}, txId=813, messageType=DELETE, lastCommitLsn=LSN{0/2127270}, timestamp=2024-02-01T07:30:07.594584Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/21272A8}, lastCommitLsn=LSN{0/2127270}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] [INFO] io.debezium.pipeline.signal.channels.FileSignalChannel - Processing signal: d139b9b7-7777-4547-917d-11111111111, execute-snapshot, {"type":"INCREMENTAL","data-collections":["inventory.products"]}, {} [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Signal Processor offset context {PostgresPartition [sourcePartition={server=testcdc}]=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='testcdc'db='postgres', lsn=LSN{0/2127270}, txId=813, messageType=DELETE, lastCommitLsn=LSN{0/2127270}, timestamp=2024-02-01T07:30:07.594584Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/21272A8}, lastCommitLsn=LSN{0/2127270}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]} [DEBUG] io.debezium.pipeline.signal.SignalProcessor - Received signal id = 'd139b9b7-7777-4547-917d-11111111111', type = 'execute-snapshot', data = '{"type":"INCREMENTAL","data-collections":["inventory.products"]}' [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Connected metrics set to 'true' [INFO] debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot - Requested 'INCREMENTAL' snapshot of data collections '[inventory.products]' with additional conditions '[]' and surrogate key 'PK of table will be used' [WARN] io.debezium.pipeline.signal.SignalProcessor - Action execute-snapshot failed. The signal SignalRecord{id='d139b9b7-7777-4547-917d-11111111111', type='execute-snapshot', data='{"type":"INCREMENTAL","data-collections":["inventory.products"]}', additionalData={}} may not have been processed. io.debezium.DebeziumException: Incremental snapshot is not properly configured, either sinalling data collection is not provided or connector-specific snapshotting not set at io.debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot.arrived(ExecuteSnapshot.java:75) ~[debezium-core-2.5.1.Final.jar:2.5.1.Final] at io.debezium.pipeline.signal.SignalProcessor.processSignal(SignalProcessor.java:191) ~[debezium-core-2.5.1.Final.jar:2.5.1.Final] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:658) ~[?:?] at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) ~[?:?] at io.debezium.pipeline.signal.SignalProcessor.lambda$process$3(SignalProcessor.java:143) ~[debezium-core-2.5.1.Final.jar:2.5.1.Final] at io.debezium.pipeline.signal.SignalProcessor.executeWithSemaphore(SignalProcessor.java:165) ~[debezium-core-2.5.1.Final.jar:2.5.1.Final] at io.debezium.pipeline.signal.SignalProcessor.process(SignalProcessor.java:138) ~[debezium-core-2.5.1.Final.jar:2.5.1.Final] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?] [DEBUG] io.debezium.jdbc.JdbcConnection - 4 table(s) will be scanned [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.customers [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.debezium_signal [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.orders [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.products [TRACE] io.debezium.jdbc.JdbcConnection - Inserting prepared statement 'SELECT relreplident FROM pg_catalog.pg_class c LEFT JOIN pg_catalog.pg_namespace n ON c.relnamespace=n.oid WHERE n.nspname=? and c.relname=?' removed from the cache [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.customers' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.debezium_signal' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.orders' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.products' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.customers' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.customers' to schemas under 'testcdc.inventory.customers' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@1e76a3d6 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.customers_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@128958fb [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.customers_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'first_name' (STRING) from column first_name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'last_name' (STRING) from column last_name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'email' (STRING) from column email varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.customers' to schema: {"name" : "testcdc.inventory.customers.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.customers' to schema: {"name" : "testcdc.inventory.customers.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "first_name", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "last_name", "index" : "2", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "email", "index" : "3", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.debezium_signal' to schemas under 'testcdc.inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'type' (STRING) from column type varchar(32, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'data' (STRING) from column data varchar(2048, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "type", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "data", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.orders' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.orders' to schemas under 'testcdc.inventory.orders' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@5b072e69 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.orders_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@10eeeec6 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.orders_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'order_date' (INT32) from column order_date date(13, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'purchaser' (INT32) from column purchaser int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'quantity' (INT32) from column quantity int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'product_id' (INT32) from column product_id int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.orders' to schema: {"name" : "testcdc.inventory.orders.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.orders' to schema: {"name" : "testcdc.inventory.orders.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "order_date", "index" : "1", "schema" : {"name" : "io.debezium.time.Date", "type" : "INT32", "optional" : "false", "default" : null, "version" : "1"}}, {"name" : "purchaser", "index" : "2", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}, {"name" : "quantity", "index" : "3", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}, {"name" : "product_id", "index" : "4", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.products' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.products' to schemas under 'testcdc.inventory.products' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@67efc7cd [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.products_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@72667619 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.products_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'name' (STRING) from column name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'description' (STRING) from column description varchar(512, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'weight' (FLOAT64) from column weight float8(17, 17) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.products' to schema: {"name" : "testcdc.inventory.products.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.products' to schema: {"name" : "testcdc.inventory.products.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "name", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "description", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}, {"name" : "weight", "index" : "3", "schema" : {"type" : "FLOAT64", "optional" : "true", "default" : null}}]} [INFO] debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource - No incremental snapshot in progress, no action needed on start [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Starting streaming [INFO] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Retrieved latest position from stored offset 'LSN{0/21272A8}' [INFO] io.debezium.connector.postgresql.connection.WalPositionLocator - Looking for WAL restart position for last commit LSN 'LSN{0/2127270}' and last change LSN 'LSN{0/21272A8}' [INFO] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Initializing PgOutput logical decoder publication [TRACE] io.debezium.jdbc.JdbcConnection - Config: {replication=database, ApplicationName=Debezium Streaming, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {replication=database, ApplicationName=Debezium Streaming, password=***, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {replication=database, ApplicationName=Debezium Streaming, password=***, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.spatial_ref_sys as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.geom as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.products_on_hand as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.customers to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.debezium_signal to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.orders to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.products to the list of captured tables [INFO] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Updating Publication with statement 'ALTER PUBLICATION dbz_publication SET TABLE "inventory"."customers", "inventory"."debezium_signal", "inventory"."orders", "inventory"."products";' [TRACE] io.debezium.jdbc.JdbcConnection - Inserting prepared statement 'select * from pg_replication_slots where slot_name = ? and database = ? and plugin = ?' removed from the cache [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium Slot Info, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium Slot Info, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium Slot Info, assumeMinServerVersion=9.4, user=postgres} [INFO] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/2127270}, catalogXmin=812] [TRACE] io.debezium.jdbc.JdbcConnection - Closing prepared statement 'select * from pg_replication_slots where slot_name = 'debezium' and database = 'postgres' and plugin = 'pgoutput'' removed from cache [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - running 'IDENTIFY_SYSTEM' to validate replication connection [TRACE] io.debezium.jdbc.JdbcConnection - running 'IDENTIFY_SYSTEM' [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - received latest xlogpos '0/21274B0' [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - found previous flushed LSN 'LSN{0/2127270}' [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - starting streaming from LSN 'LSN{0/21272A8}' [INFO] io.debezium.util.Threads - Requested thread factory for connector PostgresConnector, id = testcdc named = keep-alive [INFO] io.debezium.util.Threads - Creating thread debezium-postgresconnector-testcdc-keep-alive [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Forcing status update with replication stream [DEBUG] io.debezium.jdbc.JdbcConnection - 4 table(s) will be scanned [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.customers [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.debezium_signal [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.orders [DEBUG] io.debezium.jdbc.JdbcConnection - Retrieving columns of table inventory.products [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.customers' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.debezium_signal' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.orders' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [INFO] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'inventory.products' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.customers' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.customers' to schemas under 'testcdc.inventory.customers' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@62c43415 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.customers_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@21350e4 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.customers_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'first_name' (STRING) from column first_name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'last_name' (STRING) from column last_name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'email' (STRING) from column email varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.customers' to schema: {"name" : "testcdc.inventory.customers.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.customers' to schema: {"name" : "testcdc.inventory.customers.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "first_name", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "last_name", "index" : "2", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "email", "index" : "3", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.debezium_signal' to schemas under 'testcdc.inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'type' (STRING) from column type varchar(32, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'data' (STRING) from column data varchar(2048, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "type", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "data", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.orders' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.orders' to schemas under 'testcdc.inventory.orders' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@14c3b08 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.orders_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@40451733 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.orders_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'order_date' (INT32) from column order_date date(13, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'purchaser' (INT32) from column purchaser int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'quantity' (INT32) from column quantity int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'product_id' (INT32) from column product_id int4(10, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.orders' to schema: {"name" : "testcdc.inventory.orders.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.orders' to schema: {"name" : "testcdc.inventory.orders.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "order_date", "index" : "1", "schema" : {"name" : "io.debezium.time.Date", "type" : "INT32", "optional" : "false", "default" : null, "version" : "1"}}, {"name" : "purchaser", "index" : "2", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}, {"name" : "quantity", "index" : "3", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}, {"name" : "product_id", "index" : "4", "schema" : {"type" : "INT32", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.products' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.products' to schemas under 'testcdc.inventory.products' [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@362f7b2 [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.products_id_seq'::regclass) [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from data object: *** 0 *** [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Callback is: io.debezium.jdbc.JdbcValueConverters$$Lambda$470/0x00000008003f0040@1bee034a [TRACE] io.debezium.connector.postgresql.PostgresValueConverter - Value from ResultReceiver: [received = true, object = 0] [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (INT32) from column id serial(10, 0) NOT NULL AUTO_INCREMENTED DEFAULT VALUE nextval('inventory.products_id_seq'::regclass) [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'name' (STRING) from column name varchar(255, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'description' (STRING) from column description varchar(512, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'weight' (FLOAT64) from column weight float8(17, 17) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.products' to schema: {"name" : "testcdc.inventory.products.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.products' to schema: {"name" : "testcdc.inventory.products.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "INT32", "optional" : "false", "default" : "0"}}, {"name" : "name", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "description", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}, {"name" : "weight", "index" : "3", "schema" : {"type" : "FLOAT64", "optional" : "true", "default" : null}}]} [INFO] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Searching for WAL resume position [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: BEGIN [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - BEGIN messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 4200000000021273000002b34bbbc510580000032d2020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: BEGIN [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Final LSN of transaction: LSN{0/2127300} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit timestamp of transaction: 2024-02-01T07:30:07.594584Z [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - XID of transaction: 813 [TRACE] io.debezium.connector.postgresql.connection.WalPositionLocator - Processing LSN 'LSN{0/21272A8}', operation 'BEGIN' [INFO] io.debezium.connector.postgresql.connection.WalPositionLocator - First LSN 'LSN{0/21272A8}' received [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/0} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: RELATION [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - RELATION messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/0} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 5200006452696e76656e746f727900646562657a69756d5f7369676e616c0064000301696400000004130000002e007479706500000004130000002400646174610000000413000008042020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: RELATION, RelationId: 25682, Replica Identity: 100, Columns: 3 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Schema: 'inventory', Table: 'debezium_signal' [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Resolved 'inventory.debezium_signal' as 'columns: { id varchar(42, 0) NOT NULL type varchar(32, 0) NOT NULL data varchar(2048, 0) DEFAULT VALUE NULL } primary key: [id] default charset: null comment: null attributes: { } ' [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.debezium_signal' to schemas under 'testcdc.inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'type' (STRING) from column type varchar(32, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'data' (STRING) from column data varchar(2048, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "type", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "data", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}]} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: DELETE [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 44000064524b000374000000193131312d373737372d343534372d393137642d3232323131316e6e2020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: DELETE, RelationId: 25682, Tuple Type: K [DEBUG] io.debezium.connector.postgresql.PostgresSchema - Relation '25682' resolved to table 'inventory.debezium_signal' [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Column: id(varchar(42,0))=111-7777-4547-917d-222111 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Column: io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder$3@31851997 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Column: io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder$3@685c196c [TRACE] io.debezium.connector.postgresql.connection.WalPositionLocator - Processing LSN 'LSN{0/21272A8}', operation 'DELETE' [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: COMMIT [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - COMMIT messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 4300000000000212730000000000021273300002b34bbbc510582020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: COMMIT [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Flags: 0 (currently unused and most likely 0) [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit LSN: LSN{0/2127300} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - End LSN of transaction: LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit timestamp of transaction: 2024-02-01T07:30:07.594584Z [TRACE] io.debezium.connector.postgresql.connection.WalPositionLocator - Processing LSN 'LSN{0/2127330}', operation 'COMMIT' [INFO] io.debezium.connector.postgresql.connection.WalPositionLocator - LSN after last stored change LSN 'LSN{0/2127330}' received [INFO] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - WAL resume position 'LSN{0/2127330}' discovered [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing message decoder [TRACE] io.debezium.jdbc.JdbcConnection - Closing prepared statement 'select * from pg_replication_slots where slot_name = 'debezium' and database = 'postgres' and plugin = 'pgoutput'' removed from cache [TRACE] io.debezium.jdbc.JdbcConnection - Closing prepared statement 'SELECT relreplident FROM pg_catalog.pg_class c LEFT JOIN pg_catalog.pg_namespace n ON c.relnamespace=n.oid WHERE n.nspname='inventory' and c.relname='products'' removed from cache [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing replication connection [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [TRACE] io.debezium.jdbc.JdbcConnection - Config: {replication=database, ApplicationName=Debezium Streaming, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {replication=database, ApplicationName=Debezium Streaming, password=***, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {replication=database, ApplicationName=Debezium Streaming, password=***, assumeMinServerVersion=9.4, user=postgres, preferQueryMode=simple} [INFO] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Initializing PgOutput logical decoder publication [TRACE] io.debezium.jdbc.JdbcConnection - Config: {ApplicationName=Debezium General, hostname=localhost, password=***, dbname=postgres, port=5432, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - Props: {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.jdbc.JdbcConnection - URL: jdbc:postgresql://localhost:5432/postgres [DEBUG] io.debezium.jdbc.JdbcConnection - Connected to jdbc:postgresql://localhost:5432/postgres with {password=***, ApplicationName=Debezium General, assumeMinServerVersion=9.4, user=postgres} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.spatial_ref_sys as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.geom as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Ignoring table inventory.products_on_hand as it's not included in the filter configuration [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.customers to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.debezium_signal to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.orders to the list of captured tables [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Adding table inventory.products to the list of captured tables [INFO] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Updating Publication with statement 'ALTER PUBLICATION dbz_publication SET TABLE "inventory"."customers", "inventory"."debezium_signal", "inventory"."orders", "inventory"."products";' [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - starting streaming from LSN 'LSN{0/21272A8}' [INFO] io.debezium.util.Threads - Requested thread factory for connector PostgresConnector, id = testcdc named = keep-alive [INFO] io.debezium.util.Threads - Creating thread debezium-postgresconnector-testcdc-keep-alive [INFO] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Processing messages [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Forcing status update with replication stream [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: BEGIN [DEBUG] io.debezium.connector.postgresql.connection.WalPositionLocator - Message with LSN 'LSN{0/21272A8}' filtered [INFO] io.debezium.connector.postgresql.connection.AbstractMessageDecoder - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21272A8} identified as already processed [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - BEGIN messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 4200000000021273000002b34bbbc510580000032d2020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: BEGIN [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Final LSN of transaction: LSN{0/2127300} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit timestamp of transaction: 2024-02-01T07:30:07.594584Z [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - XID of transaction: 813 [TRACE] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Received transactional message TransactionMessage [transactionId=813, commitTime=2024-02-01T07:30:07.594584Z, operation=BEGIN] [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/0} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: RELATION [DEBUG] io.debezium.connector.postgresql.connection.WalPositionLocator - Message with LSN 'LSN{0/0}' filtered [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - RELATION messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/0} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 5200006452696e76656e746f727900646562657a69756d5f7369676e616c0064000301696400000004130000002e007479706500000004130000002400646174610000000413000008042020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: RELATION, RelationId: 25682, Replica Identity: 100, Columns: 3 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Schema: 'inventory', Table: 'debezium_signal' [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Resolved 'inventory.debezium_signal' as 'columns: { id varchar(42, 0) NOT NULL type varchar(32, 0) NOT NULL data varchar(2048, 0) DEFAULT VALUE NULL } primary key: [id] default charset: null comment: null attributes: { } ' [DEBUG] io.debezium.relational.RelationalDatabaseSchema - refreshing DB schema for table 'inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapping table 'inventory.debezium_signal' to schemas under 'testcdc.inventory.debezium_signal' [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'id' (STRING) from column id varchar(42, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'type' (STRING) from column type varchar(32, 0) NOT NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - - field 'data' (STRING) from column data varchar(2048, 0) DEFAULT VALUE NULL [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped primary key for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Key", "type" : "STRUCT", "optional" : "false", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}]} [DEBUG] io.debezium.relational.TableSchemaBuilder - Mapped columns for table 'inventory.debezium_signal' to schema: {"name" : "testcdc.inventory.debezium_signal.Value", "type" : "STRUCT", "optional" : "true", "default" : null, "fields" : [{"name" : "id", "index" : "0", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "type", "index" : "1", "schema" : {"type" : "STRING", "optional" : "false", "default" : null}}, {"name" : "data", "index" : "2", "schema" : {"type" : "STRING", "optional" : "true", "default" : null}}]} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21272A8} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: DELETE [DEBUG] io.debezium.connector.postgresql.connection.WalPositionLocator - Message with LSN 'LSN{0/21272A8}' filtered [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message Type: COMMIT [INFO] io.debezium.connector.postgresql.connection.WalPositionLocator - Message with LSN 'LSN{0/2127330}' arrived, switching off the filtering [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - COMMIT messages are always reprocessed [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Received message at LSN LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Message arrived from database 4300000000000212730000000000021273300002b34bbbc510582020 [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Event: COMMIT [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Flags: 0 (currently unused and most likely 0) [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit LSN: LSN{0/2127300} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - End LSN of transaction: LSN{0/2127330} [TRACE] debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder - Commit timestamp of transaction: 2024-02-01T07:30:07.594584Z [TRACE] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Received transactional message TransactionMessage [transactionId=813, commitTime=2024-02-01T07:30:07.594584Z, operation=COMMIT] [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine is polling task for records on thread Thread[pool-2-thread-1,5,main] [DEBUG] io.debezium.connector.base.ChangeEventQueue - polling records... [DEBUG] io.debezium.connector.base.ChangeEventQueue - no records available or batch size not reached yet, sleeping a bit... [INFO] io.debezium.embedded.EmbeddedEngine - Stopping the embedded engine [INFO] io.debezium.embedded.EmbeddedEngine - Waiting for PT5M for connector to stop [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Streaming requested from LSN LSN{0/21272A8}, received LSN LSN{0/21274B0} [TRACE] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor processing [TRACE] io.debezium.pipeline.signal.channels.SourceSignalChannel - Reading signaling events from queue [DEBUG] io.debezium.connector.base.ChangeEventQueue - checking for more records... [DEBUG] io.debezium.embedded.EmbeddedEngine - Embedded engine returned from polling task for records [DEBUG] io.debezium.embedded.EmbeddedEngine - Received no records from the task [INFO] io.debezium.embedded.EmbeddedEngine - Stopping the task and engine [INFO] io.debezium.connector.common.BaseSourceTask - Stopping down connector [DEBUG] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - stopping streaming... [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing message decoder [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing replication connection [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Finished streaming [INFO] io.debezium.pipeline.ChangeEventSourceCoordinator - Connected metrics set to 'false' [INFO] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor stopped [INFO] io.debezium.service.DefaultServiceRegistry - Debezium ServiceRegistry stopped. [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing message decoder [DEBUG] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Closing replication connection [TRACE] io.debezium.jdbc.JdbcConnection - Closing database connection [INFO] io.debezium.jdbc.JdbcConnection - Connection gracefully closed [DEBUG] io.debezium.connector.common.BaseSourceTask - Setting task state to 'STOPPED', previous state was 'RUNNING' [DEBUG] io.debezium.embedded.EmbeddedEngine - Interrupting the embedded engine's thread Thread[pool-2-thread-1,5,main] (already interrupted: false) [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Debezium ended successfully with 'Connector 'io.debezium.connector.postgresql.PostgresConnector' completed normally.' [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Debezium ended successfully with 'Connector 'io.debezium.connector.postgresql.PostgresConnector' completed normally.' [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Ended after receiving records: 0 [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Ended after receiving records: 0 [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Engine terminated [INFO] keboola.cdc.debezium.DebeziumKBCWrapper - Engine terminated Process finished with exit code 0