__ __ _
____/ /___ / /_ ___ ____ (_)__ __ ____ ___
/ __ // _ \ / __ \ / _ \/_ / / // / / // __ `__ \
/ /_/ // __// /_/ // __/ / /_ / // /_/ // / / / / /
\__,_/ \___//_.___/ \___/ /___//_/ \__,_//_/ /_/ /_/



Powered by Quarkus 3.15.3
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) ---------------------------------------------------------------------
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Legacy REST API date formats enabled (this is currently the default).
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main)
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) For maximum compatibility and to ease upgrades from older versions
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) of Registry, the date format used in the REST API is not compliant
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) with OpenAPI standards (due to a bug in older versions). Please
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) make sure you upgrade all of your client applications to use the
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) latest client version. The next release will fix the date format
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) bug, which will result in older clients no longer being compatible
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) with the REST API.
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main)
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) If you would like to fix the date format bug in THIS version of
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Registry (great!) please set the following ENV variable + value:
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main)
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) REGISTRY_APIS_V2_DATE_FORMAT=yyyy-MM-dd'T'HH:mm:ss'Z'
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main)
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) Doing this will result in a REST API that is OpenAPI compliant, but
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) please remember to upgrade all your client applications first!
2025-04-25 14:17:34,772 INFO [io.api.reg.res.JacksonDateTimeCustomizer] (main) ---------------------------------------------------------------------
2025-04-25 14:17:35,379 INFO [io.deb.ser.BaseChangeConsumer] (main) Using 'io.debezium.server.BaseChangeConsumer$$Lambda/0x00007f0f133856f8@51b77cdf' stream name mapper
2025-04-25 14:17:35,421 INFO [io.deb.ser.DebeziumServer] (main) Consumer 'io.debezium.server.nats.jetstream.NatsJetStreamChangeConsumer' instantiated
2025-04-25 14:17:35,500 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

2025-04-25 14:17:35,502 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

2025-04-25 14:17:35,502 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

2025-04-25 14:17:35,526 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 = 0
offset.flush.timeout.ms = 5000
offset.storage.file.filename = /offset/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

2025-04-25 14:17:35,555 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

2025-04-25 14:17:35,556 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

2025-04-25 14:17:35,556 INFO [io.deb.ser.DebeziumServer] (main) Engine executor started
2025-04-25 14:17:35,556 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'CREATING' to 'INITIALIZING'
2025-04-25 14:17:35,579 INFO [io.deb.con.CommonConnectorConfig] (pool-7-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,585 INFO [io.deb.con.CommonConnectorConfig] (pool-7-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,586 INFO [io.deb.con.CommonConnectorConfig] (pool-7-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,657 INFO [io.quarkus] (main) debezium-server-dist 3.1.1.Final on JVM (powered by Quarkus 3.15.3) started in 1.771s. Listening on: http://0.0.0.0:8080
2025-04-25 14:17:35,658 INFO [io.quarkus] (main) Profile prod activated.
2025-04-25 14:17:35,658 INFO [io.quarkus] (main) Installed features: [cdi, config-yaml, kubernetes-client, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health, vertx]
2025-04-25 14:17:35,662 INFO [org.mon.dri.cluster] (pool-7-thread-1) Adding discovered server mongodb-0.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,695 INFO [org.mon.dri.cluster] (pool-7-thread-1) Adding discovered server mongodb-1.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,698 INFO [org.mon.dri.cluster] (pool-7-thread-1) Adding discovered server mongodb-2.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,718 INFO [org.mon.dri.client] (pool-7-thread-1) MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "5.2.0"}, "os": {"type": "Linux", "name": "Linux", "architecture": "amd64", "version": "5.15.0-1081-azure"}, "platform": "Java/Red Hat, Inc./21.0.7+6-LTS", "env": {"container": {"orchestrator": "kubernetes"}}} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null, userName='debezium', source='admin', password=<hidden>, mechanismProperties=<hidden>}, transportSettings=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.client.model.mql.ExpressionCodecProvider@1e3939d3, com.mongodb.Jep395RecordCodecProvider@4a3953ba, com.mongodb.KotlinCodecProvider@11d0d582]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[mongodb-0.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-2.mongodb.cluster.local:27017], srvServiceName=mongodb, mode=MULTIPLE, requiredClusterType=REPLICA_SET, requiredReplicaSetName='rs', serverSelector='null', clusterListeners='[]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverMonitoringMode=AUTO, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=javax.net.ssl.SSLContext@18e037c1}, applicationName='null', compressorList=[], uuidRepresentation=STANDARD, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null, timeoutMS=null}
2025-04-25 14:17:35,737 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-0.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-0.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=19041020, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-0.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=680aff4859f040088ba67f87, counter=4}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879373968556}
2025-04-25 14:17:35,737 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-1.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-1.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=19044073, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-1.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=68079a048fd48528895281a7, counter=5}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879373971711}
2025-04-25 14:17:35,738 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-2.mongodb.cluster.local:27017, type=REPLICA_SET_PRIMARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=19052985, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-2.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000156, setVersion=8, topologyVersion=TopologyVersion{processId=680796ee3e1c49ab3ad5cc76, counter=7}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879373977358}
2025-04-25 14:17:35,746 INFO [org.mon.dri.cluster] (pool-7-thread-1) Waiting for server to become available for operation with ID 5. Remaining time: 29994 ms. Selector: ReadPreferenceServerSelector{readPreference=primary}, topology description: {type=REPLICA_SET, servers=[{address=mongodb-1.mongodb.cluster.local:27017, type=UNKNOWN, state=CONNECTING}, {address=mongodb-0.mongodb.cluster.local:27017, type=UNKNOWN, state=CONNECTING}, {address=mongodb-2.mongodb.cluster.local:27017, type=UNKNOWN, state=CONNECTING}].
2025-04-25 14:17:35,747 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Discovered replica set primary mongodb-2.mongodb.cluster.local:27017 with max election id 7fffffff0000000000000156 and max set version 8
2025-04-25 14:17:35,826 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

2025-04-25 14:17:35,827 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Starting FileOffsetBackingStore with file /offset/offsets.dat
2025-04-25 14:17:35,861 INFO [io.deb.con.mon.MongoDbConnector] (pool-7-thread-1) Successfully started MongoDB connector
2025-04-25 14:17:35,861 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'INITIALIZING' to 'CREATING_TASKS'
2025-04-25 14:17:35,868 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'CREATING_TASKS' to 'STARTING_TASKS'
2025-04-25 14:17:35,869 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Waiting max. for 180000 ms for individual source tasks to start.
2025-04-25 14:17:35,871 INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Starting MongoDbConnectorTask with configuration:
connector.class = io.debezium.connector.mongodb.MongoDbConnector
schema.history.internal.nats-jetstream.create-stream = false
collection.include.list = backend.table_1,backend.emails,backend.table_3
mongodb.connection.string = ********
tasks.max = 1
record.processing.shutdown.timeout.ms = 1000
filters.match.mode = literal
capture.mode = change_streams_update_full
transforms = unwrap
record.processing.order = ORDERED
topic.prefix = DebeziumStream
offset.storage.file.filename = /offset/offsets.dat
schema.history.internal.nats-jetstream.url = nats://nats-cluster.cluster.local:4222
transforms.unwrap.delete.tombstone.handling.mode.rewrite-with-id = true
record.processing.threads =
transforms.unwrap.type = io.debezium.connector.mongodb.transforms.ExtractNewDocumentState
errors.retry.delay.initial.ms = 300
value.converter = org.apache.kafka.connect.json.JsonConverter
value.converter.value.schemas.enable = false
key.converter = org.apache.kafka.connect.json.JsonConverter
offset.storage.nats-jetstream.create-stream = false
offset.storage.nats-jetstream.subjects = DebeziumStream.>
header.converter.value = json
header.converter.value.schemas.enable = false
transforms.unwrap.delete.tombstone.handling.mode = rewrite
offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
key.converter.value = json
key.converter.value.schemas.enable = false
offset.flush.timeout.ms = 5000
errors.retry.delay.max.ms = 10000
schema.history.internal.nats-jetstream.subjects = DebeziumStream.>
transforms.unwrap.flatten.struct.delimiter = __
value.converter.value = json
offset.flush.interval.ms = 0
internal.task.management.timeout.ms = 180000
record.processing.with.serial.consumer = false
offset.storage.nats-jetstream.url = nats://nats-cluster.cluster.local:4222
errors.max.retries = -1
value.converter.schemas.enable = false
name = nats-jetstream
transforms.unwrap.add.fields = op,source.ts_ms:ts_ms,collection,name,version
transforms.unwrap.flatten.struct = true
database.include.list = backend
snapshot.mode = no_data

2025-04-25 14:17:35,872 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,873 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,873 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,874 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,879 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,880 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy
2025-04-25 14:17:35,880 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,881 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,881 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,895 INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Found previous partition offset MongoDbPartition [sourcePartition={server_id=DebeziumStream}]: {sec=1745418777, ord=1, resume_token=<token>}
2025-04-25 14:17:35,903 INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component MongoDbConnector, id = DebeziumStream named = SignalProcessor
2025-04-25 14:17:35,923 WARN [io.deb.sna.SnapshotLockProvider] (pool-10-thread-1) Found a not connector specific implementation io.debezium.snapshot.lock.NoLockingSupport for lock mode no_locking_support
2025-04-25 14:17:35,938 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,939 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,939 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,940 INFO [io.deb.con.CommonConnectorConfig] (pool-10-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:35,941 INFO [io.deb.con.mon.con.MongoDbConnection] (pool-10-thread-1) Found existing offset for at {sec=1745418777, ord=1, resume_token=<token>}
2025-04-25 14:17:35,942 INFO [org.mon.dri.cluster] (pool-10-thread-1) Adding discovered server mongodb-0.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,945 INFO [org.mon.dri.cluster] (pool-10-thread-1) Adding discovered server mongodb-1.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,947 INFO [org.mon.dri.cluster] (pool-10-thread-1) Adding discovered server mongodb-2.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:35,948 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-0.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-0.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=1772348, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-0.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=680aff4859f040088ba67f87, counter=4}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879593259828}
2025-04-25 14:17:35,949 INFO [org.mon.dri.client] (pool-10-thread-1) MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "5.2.0"}, "os": {"type": "Linux", "name": "Linux", "architecture": "amd64", "version": "5.15.0-1081-azure"}, "platform": "Java/Red Hat, Inc./21.0.7+6-LTS", "env": {"container": {"orchestrator": "kubernetes"}}} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null, userName='debezium', source='admin', password=<hidden>, mechanismProperties=<hidden>}, transportSettings=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.client.model.mql.ExpressionCodecProvider@1e3939d3, com.mongodb.Jep395RecordCodecProvider@4a3953ba, com.mongodb.KotlinCodecProvider@11d0d582]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[mongodb-0.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-2.mongodb.cluster.local:27017], srvServiceName=mongodb, mode=MULTIPLE, requiredClusterType=REPLICA_SET, requiredReplicaSetName='rs', serverSelector='null', clusterListeners='[]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverMonitoringMode=AUTO, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=javax.net.ssl.SSLContext@4e1eed35}, applicationName='null', compressorList=[], uuidRepresentation=STANDARD, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null, timeoutMS=null}
2025-04-25 14:17:35,950 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-1.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-1.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2944281, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-1.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=68079a048fd48528895281a7, counter=5}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879595929669}
2025-04-25 14:17:35,952 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-2.mongodb.cluster.local:27017, type=REPLICA_SET_PRIMARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2746094, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-2.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000156, setVersion=8, topologyVersion=TopologyVersion{processId=680796ee3e1c49ab3ad5cc76, counter=7}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879596766027}
2025-04-25 14:17:35,952 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Discovered replica set primary mongodb-2.mongodb.cluster.local:27017 with max election id 7fffffff0000000000000156 and max set version 8
2025-04-25 14:17:35,964 INFO [io.deb.con.mon.ChangeStreamPipelineFactory] (pool-10-thread-1) Effective change stream pipeline: [{"$match": {"$and": [{"$and": [{"ns.db": {"$in": ["backend"]}}, {"ns": {"$in": [{"db": "backend", "coll": "table_1"}, {"db": "backend", "coll": "emails"}, {"db": "backend", "coll": "table_3"}]}}]}, {"operationType": {"$in": ["insert", "update", "replace", "delete"]}}]}}]
2025-04-25 14:17:36,097 INFO [io.deb.con.mon.con.MongoDbConnection] (pool-10-thread-1) Valid resume token present, so no snapshot will be performed'
2025-04-25 14:17:36,107 INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component MongoDbConnector, id = DebeziumStream named = change-event-source-coordinator
2025-04-25 14:17:36,107 INFO [io.deb.uti.Threads] (pool-10-thread-1) Requested thread factory for component MongoDbConnector, id = DebeziumStream named = blocking-snapshot
2025-04-25 14:17:36,109 INFO [io.deb.uti.Threads] (pool-10-thread-1) Creating thread debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator
2025-04-25 14:17:36,110 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) All tasks have started successfully.
2025-04-25 14:17:36,110 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'STARTING_TASKS' to 'POLLING_TASKS'
2025-04-25 14:17:36,111 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Using io.debezium.embedded.async.ParallelSmtAndConvertBatchProcessor processor
2025-04-25 14:17:36,182 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Metrics registered
2025-04-25 14:17:36,182 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Context created
2025-04-25 14:17:36,185 INFO [io.deb.con.mon.MongoDbSnapshotChangeEventSource] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) A previous offset indicating a completed snapshot has been found.
2025-04-25 14:17:36,185 INFO [io.deb.con.mon.MongoDbSnapshotChangeEventSource] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) According to the connector configuration, no snapshot will occur.
2025-04-25 14:17:36,192 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Snapshot ended with SnapshotResult [status=SKIPPED, offset=MongoDbOffsetContext [sourceInfo=SourceInfo [initialSync=false, collectionId=null, position=Position [ts=Timestamp{value=7496516565039316993, seconds=1745418777, inc=1}, changeStreamSessionTxnId=null, resumeToken=<token>]]]]
2025-04-25 14:17:36,193 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Connected metrics set to 'true'
2025-04-25 14:17:36,195 INFO [io.deb.uti.Threads] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Requested thread factory for component MongoDbConnector, id = mongodb named = incremental-snapshot
2025-04-25 14:17:36,196 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,196 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,197 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,198 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,198 INFO [io.deb.con.mon.sna.MongoDbIncrementalSnapshotChangeEventSource] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) No incremental snapshot in progress, no action needed on start
2025-04-25 14:17:36,205 INFO [io.deb.pip.sig.SignalProcessor] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) SignalProcessor started. Scheduling it every 5000ms
2025-04-25 14:17:36,205 INFO [io.deb.uti.Threads] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Creating thread debezium-mongodbconnector-DebeziumStream-SignalProcessor
2025-04-25 14:17:36,205 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Starting streaming
2025-04-25 14:17:36,205 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,206 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,206 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,207 INFO [io.deb.con.CommonConnectorConfig] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
2025-04-25 14:17:36,208 INFO [org.mon.dri.cluster] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Adding discovered server mongodb-0.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:36,209 INFO [org.mon.dri.cluster] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Adding discovered server mongodb-1.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:36,210 INFO [org.mon.dri.cluster] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Adding discovered server mongodb-2.mongodb.cluster.local:27017 to client view of cluster
2025-04-25 14:17:36,211 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-0.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-0.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=1567094, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-0.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=680aff4859f040088ba67f87, counter=4}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879856670341}
2025-04-25 14:17:36,211 INFO [org.mon.dri.client] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "5.2.0"}, "os": {"type": "Linux", "name": "Linux", "architecture": "amd64", "version": "5.15.0-1081-azure"}, "platform": "Java/Red Hat, Inc./21.0.7+6-LTS", "env": {"container": {"orchestrator": "kubernetes"}}} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null, userName='debezium', source='admin', password=<hidden>, mechanismProperties=<hidden>}, transportSettings=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.client.model.mql.ExpressionCodecProvider@1e3939d3, com.mongodb.Jep395RecordCodecProvider@4a3953ba, com.mongodb.KotlinCodecProvider@11d0d582]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[mongodb-0.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-2.mongodb.cluster.local:27017], srvServiceName=mongodb, mode=MULTIPLE, requiredClusterType=REPLICA_SET, requiredReplicaSetName='rs', serverSelector='null', clusterListeners='[]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverMonitoringMode=AUTO, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=javax.net.ssl.SSLContext@4de9e1b5}, applicationName='null', compressorList=[], uuidRepresentation=STANDARD, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null, timeoutMS=null}
2025-04-25 14:17:36,212 INFO [io.deb.con.mon.MongoDbStreamingChangeEventSource] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Reading change stream
2025-04-25 14:17:36,213 INFO [io.deb.con.mon.ChangeStreamPipelineFactory] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Effective change stream pipeline: [{"$match": {"$and": [{"$and": [{"ns.db": {"$in": ["backend"]}}, {"ns": {"$in": [{"db": "backend", "coll": "table_1"}, {"db": "backend", "coll": "table_2"}, {"db": "backend", "coll": "table_3"}]}}]}, {"operationType": {"$in": ["insert", "update", "replace", "delete"]}}]}}]
2025-04-25 14:17:36,213 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-1.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-1.mongodb.cluster.local:27017, type=REPLICA_SET_SECONDARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2609456, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-1.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=null, setVersion=8, topologyVersion=TopologyVersion{processId=68079a048fd48528895281a7, counter=5}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879858750043}
2025-04-25 14:17:36,214 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Monitor thread successfully connected to server with description ServerDescription{address=mongodb-2.mongodb.cluster.local:27017, type=REPLICA_SET_PRIMARY, cryptd=false, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2484648, minRoundTripTimeNanos=0, setName='rs', canonicalAddress=mongodb-2.mongodb.cluster.local:27017, hosts=[mongodb-2.mongodb.cluster.local:27017, mongodb-1.mongodb.cluster.local:27017, mongodb-0.mongodb.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-2.mongodb.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000156, setVersion=8, topologyVersion=TopologyVersion{processId=680796ee3e1c49ab3ad5cc76, counter=7}, lastWriteDate=Fri Apr 25 14:17:27 UTC 2025, lastUpdateTimeNanos=3206879859485398}
2025-04-25 14:17:36,214 INFO [org.mon.dri.cluster] (cluster-ClusterId{value='xxxxxxxxxxxxx', description='null'}-mongodb-2.mongodb.cluster.local:27017) Discovered replica set primary mongodb-2.mongodb.cluster.local:27017 with max election id 7fffffff0000000000000156 and max set version 8
2025-04-25 14:17:36,215 INFO [io.deb.con.mon.MongoDbStreamingChangeEventSource] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Resuming streaming from token '<token>'
2025-04-25 14:17:36,217 INFO [io.deb.uti.Threads] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Requested thread factory for component MongoDbConnector, id = DebeziumStream named = replicator-fetcher
2025-04-25 14:17:36,217 INFO [io.deb.con.mon.eve.BufferingChangeStreamCursor] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Fetcher submitted for execution: io.debezium.connector.mongodb.events.BufferingChangeStreamCursor$EventFetcher@7012cf48 @ java.util.concurrent.ThreadPoolExecutor@77204ee1[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
2025-04-25 14:17:36,217 INFO [io.deb.uti.Threads] (debezium-mongodbconnector-DebeziumStream-change-event-source-coordinator) Creating thread debezium-mongodbconnector-DebeziumStream-replicator-fetcher-0
2025-04-25 14:17:36,645 ERROR [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine has failed with : java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.DataException: <field> is not a valid field name
at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191)
at io.debezium.embedded.async.AsyncEmbeddedEngine.runTasksPolling(AsyncEmbeddedEngine.java:496)
at io.debezium.embedded.async.AsyncEmbeddedEngine.run(AsyncEmbeddedEngine.java:220)
at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:182)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.DataException: <field> is not a valid field name
at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191)
at io.debezium.embedded.async.ParallelSmtAndConvertBatchProcessor.processRecords(ParallelSmtAndConvertBatchProcessor.java:49)
at io.debezium.embedded.async.AsyncEmbeddedEngine$PollRecords.doCall(AsyncEmbeddedEngine.java:1203)
at io.debezium.embedded.async.AsyncEmbeddedEngine$PollRecords.doCall(AsyncEmbeddedEngine.java:1183)
at io.debezium.embedded.async.RetryingCallable.call(RetryingCallable.java:47)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
... 3 more
Caused by: org.apache.kafka.connect.errors.DataException: <field> is not a valid field name
at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254)
at org.apache.kafka.connect.data.Struct.put(Struct.java:202)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:217)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:154)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:268)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.lambda$convertFieldValue$0(MongoDataConverter.java:192)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1116)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:184)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:268)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.lambda$convertFieldValue$0(MongoDataConverter.java:192)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1116)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:184)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:154)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:268)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.lambda$convertFieldValue$0(MongoDataConverter.java:192)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1116)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:184)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:154)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertFieldValue(MongoDataConverter.java:154)
at io.debezium.connector.mongodb.transforms.MongoDataConverter.convertRecord(MongoDataConverter.java:63)
at io.debezium.connector.mongodb.transforms.ExtractNewDocumentState.newRecord(ExtractNewDocumentState.java:292)
at io.debezium.connector.mongodb.transforms.ExtractNewDocumentState.doApply(ExtractNewDocumentState.java:234)
at io.debezium.transforms.AbstractExtractNewRecordState.apply(AbstractExtractNewRecordState.java:119)
at io.debezium.embedded.Transformations.transform(Transformations.java:92)
at io.debezium.embedded.async.ProcessingCallables$TransformAndConvertRecord.call(ProcessingCallables.java:80)
... 4 more

2025-04-25 14:17:36,646 INFO [io.deb.emb.asy.AsyncEmbeddedEngine] (pool-7-thread-1) Engine state has changed from 'POLLING_TASKS' to 'STOPPING'
2025-04-25 14:17:36,841 INFO [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Stopping down connector