2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) --------------------------------------------------------------------- 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Legacy REST API date formats enabled (this is currently the default). 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) For maximum compatibility and to ease upgrades from older versions 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) of Registry, the date format used in the REST API is not compliant 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) with OpenAPI standards (due to a bug in older versions). Please 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) make sure you upgrade all of your client applications to use the 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) latest client version. The next release will fix the date format 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) bug, which will result in older clients no longer being compatible 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) with the REST API. 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) If you would like to fix the date format bug in THIS version of 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Registry (great!) please set the following ENV variable + value: 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) REGISTRY_APIS_V2_DATE_FORMAT=yyyy-MM-dd'T'HH:mm:ss'Z' 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Doing this will result in a REST API that is OpenAPI compliant, but 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) please remember to upgrade all your client applications first! 2024-10-05 03:27:25,980 inv-tst io.debezium.server.Main[13471] INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) --------------------------------------------------------------------- 2024-10-05 03:27:26,623 inv-tst io.debezium.server.Main[13471] WARN [io.qua.config] (main) Unrecognized configuration file file:/home/sasha_nhard/debezium-setup/debezium-server-dist/debezium-server-final/config/application.properties.example found; Please, check if your are providing the proper extension to load the file 2024-10-05 03:27:26,623 inv-tst io.debezium.server.Main[13471] WARN [io.qua.config] (main) Unrecognized configuration file file:/home/sasha_nhard/debezium-setup/debezium-server-dist/debezium-server-final/config/application.properties.cassandra.redis.example found; Please, check if your are providing the proper extension to load the file 2024-10-05 03:27:26,745 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.BaseChangeConsumer] (main) Using 'io.debezium.server.BaseChangeConsumer$$Lambda/0x00007f17233a9b98@2c63762b' stream name mapper 2024-10-05 03:27:26,761 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.rab.RabbitMqStreamChangeConsumer] (main) Using connection to localhost:5672 2024-10-05 03:27:26,814 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.DebeziumServer] (main) Consumer 'io.debezium.server.rabbitmq.RabbitMqStreamChangeConsumer' instantiated 2024-10-05 03:27:26,884 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = header decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2024-10-05 03:27:26,886 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2024-10-05 03:27:26,887 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2024-10-05 03:27:26,917 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.EmbeddedWorkerConfig] (main) EmbeddedWorkerConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 2000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = ./data-db2/offsets.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 2024-10-05 03:27:26,921 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2024-10-05 03:27:26,922 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2024-10-05 03:27:26,922 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.DebeziumServer] (main) Engine executor started 2024-10-05 03:27:26,922 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'CREATING' to 'INITIALIZING' 2024-10-05 03:27:26,944 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.jso.JsonConverterConfig] (pool-7-thread-1) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2024-10-05 03:27:26,945 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Starting FileOffsetBackingStore with file ./data-db2/offsets.dat 2024-10-05 03:27:26,968 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'INITIALIZING' to 'CREATING_TASKS' 2024-10-05 03:27:26,978 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'CREATING_TASKS' to 'STARTING_TASKS' 2024-10-05 03:27:26,979 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Waiting max. for 180000 ms for individual source tasks to start. 2024-10-05 03:27:26,981 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Starting As400ConnectorTask with configuration: 2024-10-05 03:27:26,984 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) connector.class = io.debezium.connector.db2as400.As400RpcConnector 2024-10-05 03:27:26,984 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.rabbitmq.connection.username = debezium-db2 2024-10-05 03:27:26,984 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) record.processing.shutdown.timeout.ms = 1000 2024-10-05 03:27:26,985 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.rabbitmq.connection.port = 5672 2024-10-05 03:27:26,985 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) schema.history.internal.rabbitmq.connection.port = 5672 2024-10-05 03:27:26,985 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) record.processing.order = ORDERED 2024-10-05 03:27:26,985 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) tombstones.on.delete = false 2024-10-05 03:27:26,985 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) topic.prefix = PUB400.COM 2024-10-05 03:27:26,986 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) decimal.handling.mode = string 2024-10-05 03:27:26,986 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.file.filename = ./data-db2/offsets.dat 2024-10-05 03:27:26,994 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.rabbitmq.exchange = db2.exchange 2024-10-05 03:27:26,994 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.schema = AZIZACALM2 2024-10-05 03:27:26,994 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) record.processing.threads = 2024-10-05 03:27:26,994 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) errors.retry.delay.initial.ms = 300 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) value.converter = org.apache.kafka.connect.json.JsonConverter 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) key.converter = org.apache.kafka.connect.json.JsonConverter 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) schema.history.internal.rabbitmq.connection.password = ******** 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.user = azizacalm 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.dbname = AZIZACALM2 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore 2024-10-05 03:27:26,995 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.rabbitmq.connection.password = ******** 2024-10-05 03:27:26,996 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.flush.timeout.ms = 5000 2024-10-05 03:27:26,996 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) errors.retry.delay.max.ms = 10000 2024-10-05 03:27:26,996 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.port = 446 2024-10-05 03:27:26,996 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) schema.history.internal.rabbitmq.connection.host = localhost 2024-10-05 03:27:26,996 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.flush.interval.ms = 2000 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) internal.task.management.timeout.ms = 180000 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) offset.storage.rabbitmq.connection.host = localhost 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) record.processing.with.serial.consumer = false 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) errors.max.retries = -1 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.hostname = PUB400.COM 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) database.password = ******** 2024-10-05 03:27:26,997 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) name = rabbitmq 2024-10-05 03:27:26,998 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) schema.history.internal.rabbitmq.connection.username = debezium-db2 2024-10-05 03:27:26,998 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) schema.history.internal.rabbitmq.exchange = db2.exchange 2024-10-05 03:27:26,998 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) table.include.list = AZIZACALM2.TEST_TABLE 2024-10-05 03:27:27,001 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400ConnectorTask] (pool-10-thread-1) starting connector task 3.0.0.Final 2024-10-05 03:27:27,020 inv-tst io.debezium.server.Main[13471] INFO [io.quarkus] (main) debezium-server-dist 3.0.0.Final on JVM (powered by Quarkus 3.8.5) started in 1.760s. Listening on: http://0.0.0.0:8083 2024-10-05 03:27:27,021 inv-tst io.debezium.server.Main[13471] INFO [io.quarkus] (main) Profile prod activated. 2024-10-05 03:27:27,021 inv-tst io.debezium.server.Main[13471] INFO [io.quarkus] (main) Installed features: [cdi, kubernetes-client, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health, vertx] 2024-10-05 03:27:27,028 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom topic naming strategy plugin: io.debezium.connector.db2as400.HostnamePrefixNamingScheme 2024-10-05 03:27:30,213 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Found previous partition offset io.debezium.connector.db2as400.As400Partition@6d20c42a: {offset.receiver_library=AZIZACALM2, offset.event_sequence=470, offset.time=1727983336, offset.receiver=TEST_T0011, table.include.list=AZIZACALM2.TEST_TABLE, offset.processed=true, snapshot_completed=true} 2024-10-05 03:27:30,507 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400RpcConnection] (pool-10-thread-1) create new as400 connection 2024-10-05 03:27:31,823 inv-tst io.debezium.server.Main[13471] ERROR [io.deb.ibm.db2.jou.ret.RetrieveConfigBuilder] (pool-10-thread-1) ignoring dump folder null as it doesn't exist 2024-10-05 03:27:31,835 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400ConnectorTask] (pool-10-thread-1) previous includes AZIZACALM2.TEST_TABLE , new includes AZIZACALM2.TEST_TABLE 2024-10-05 03:27:31,835 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400ConnectorTask] (pool-10-thread-1) no new tables to stream 2024-10-05 03:27:31,850 inv-tst io.debezium.server.Main[13471] INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component As400RpcConnector, id = PUB400.COM named = SignalProcessor 2024-10-05 03:27:31,853 inv-tst io.debezium.server.Main[13471] INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component As400RpcConnector, id = PUB400.COM named = change-event-source-coordinator 2024-10-05 03:27:31,853 inv-tst io.debezium.server.Main[13471] INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component As400RpcConnector, id = PUB400.COM named = blocking-snapshot 2024-10-05 03:27:31,854 inv-tst io.debezium.server.Main[13471] INFO [io.deb.uti.Threads] (pool-10-thread-1) Creating thread debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator 2024-10-05 03:27:31,855 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) All tasks have started successfully. 2024-10-05 03:27:31,856 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'STARTING_TASKS' to 'POLLING_TASKS' 2024-10-05 03:27:31,856 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Using io.debezium.embedded.async.ParallelSmtAndConvertBatchProcessor processor 2024-10-05 03:27:31,858 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Metrics registered 2024-10-05 03:27:31,858 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Context created 2024-10-05 03:27:31,862 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400SnapshotChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) A previous offset indicating a completed snapshot has been found. Neither schema nor data will be snapshotted. 2024-10-05 03:27:31,862 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400SnapshotChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) snapshotting skipped but fetching structure 2024-10-05 03:27:32,430 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400SnapshotChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Reading structure of schema 'AZIZACALM2' 2024-10-05 03:27:34,622 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400JdbcConnection] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) fetched 6 long names 2024-10-05 03:27:35,379 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400SnapshotChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) finished fetching structure 2024-10-05 03:27:35,384 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Snapshot ended with SnapshotResult [status=SKIPPED, offset=As400OffsetContext [position=JournalProcessedPosition [offset=470, receiver=JournalReceiver[name=TEST_T0011, library=AZIZACALM2], timeOfLastProcessed=2024-10-03T19:22:16Z, processed=true]]] 2024-10-05 03:27:35,392 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.sig.SignalProcessor] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) SignalProcessor started. Scheduling it every 5000ms 2024-10-05 03:27:35,392 inv-tst io.debezium.server.Main[13471] INFO [io.deb.uti.Threads] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Creating thread debezium-as400rpcconnector-PUB400.COM-SignalProcessor 2024-10-05 03:27:35,393 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Starting streaming 2024-10-05 03:27:36,487 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400RpcConnection] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Current position diagnostics '{position=JournalProcessedPosition [offset=470, receiver=JournalReceiver[name=TEST_T0011, library=AZIZACALM2], timeOfLastProcessed=2024-10-03T19:22:16Z, processed=true], header=FirstHeader [totalBytes=2398, offset=64, size=7, status=DATA, nextPosition=JournalProcessedPosition [offset=476, receiver=JournalReceiver[name=TEST_T0011, library=AZIZACALM2], timeOfLastProcessed=1970-01-01T00:00:00Z, processed=true]], behind=6, success=true, currentReceiver=JournalPosition[offset=476, receiver=JournalReceiver[name=TEST_T0011, library=AZIZACALM2]]}' 2024-10-05 03:27:36,488 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) next event: 2024-10-03T19:22:16.818016Z - 471 type: UP table: TEST_TABLE 2024-10-05 03:27:36,489 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) before image not found for AZIZACALM2-TEST_TABLE 2024-10-05 03:27:36,832 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) update event id 471 tx 0 table PUB400.AZIZACALM2.TEST_TABLE 2024-10-05 03:27:36,839 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) excluding table TEST_TABLE entry type CL 2024-10-05 03:27:36,839 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) excluding table TEST_TABLE entry type OP 2024-10-05 03:27:36,839 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) excluding table TEST_TABLE entry type CL 2024-10-05 03:27:36,839 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) excluding table TEST_TABLE entry type OP 2024-10-05 03:27:36,839 inv-tst io.debezium.server.Main[13471] DEBUG [io.deb.con.db2.As400StreamingChangeEventSource] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) excluding table TEST_TABLE entry type CL 2024-10-05 03:27:36,870 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) 1 records sent during previous 00:00:09.894, last recorded offset of {server=PUB400.COM} partition is {offset.receiver_library=AZIZACALM2, offset.event_sequence=470, offset.time=1727983336, offset.receiver=TEST_T0011, table.include.list=AZIZACALM2.TEST_TABLE, offset.processed=true, snapshot_completed=true} 2024-10-05 03:27:48,874 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.DebeziumServer] (Shutdown thread) Received request to stop the engine 2024-10-05 03:27:48,874 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (Shutdown thread) Engine state has changed from 'POLLING_TASKS' to 'STOPPING' 2024-10-05 03:27:48,875 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Task interrupted while polling. 2024-10-05 03:27:48,875 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Stopping down connector 2024-10-05 03:27:48,893 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Finished streaming 2024-10-05 03:27:48,894 inv-tst io.debezium.server.Main[13471] INFO [io.deb.con.db2.As400StreamingChangeEventSource] (watchdog_debezium-as400rpcconnector-PUB400.COM-change-event-source-coordinator) Interrupted is shuttingdown: true 2024-10-05 03:27:48,895 inv-tst io.debezium.server.Main[13471] INFO [io.deb.pip.sig.SignalProcessor] (pool-10-thread-1) SignalProcessor stopped 2024-10-05 03:27:48,895 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.DefaultServiceRegistry] (pool-10-thread-1) Debezium ServiceRegistry stopped. 2024-10-05 03:27:48,896 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (Shutdown thread) Stopped task #1 out of 1 tasks (it took 20 ms to stop the task). 2024-10-05 03:27:48,896 inv-tst io.debezium.server.Main[13471] INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (Shutdown thread) Stopped FileOffsetBackingStore 2024-10-05 03:27:48,897 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine is stopped. 2024-10-05 03:27:48,897 inv-tst io.debezium.server.Main[13471] INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'STOPPING' to 'STOPPED' 2024-10-05 03:27:48,897 inv-tst io.debezium.server.Main[13471] INFO [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'true', message = 'Connector 'io.debezium.connector.db2as400.As400RpcConnector' completed normally.', error = 'null' 2024-10-05 03:27:48,912 inv-tst io.debezium.server.Main[13471] INFO [io.quarkus] (Shutdown thread) debezium-server-dist stopped in 0.048s