Skip to content

Instantly share code, notes, and snippets.

@zhiyue
Created August 16, 2021 07:39
Show Gist options
  • Save zhiyue/015e64b5d9c7cdc6b2ad10de752da113 to your computer and use it in GitHub Desktop.
Save zhiyue/015e64b5d9c7cdc6b2ad10de752da113 to your computer and use it in GitHub Desktop.
connect_1 | 2021-08-16 07:28:05,406 INFO || Creating task mongo-material-0 [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,407 INFO || ConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig]
connect_1 | 2021-08-16 07:28:05,407 INFO || EnrichedConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
connect_1 | 2021-08-16 07:28:05,409 INFO || TaskConfig values:
connect_1 | task.class = class io.debezium.connector.mongodb.MongoDbConnectorTask
connect_1 | [org.apache.kafka.connect.runtime.TaskConfig]
connect_1 | 2021-08-16 07:28:05,410 INFO || Instantiated task mongo-material-0 with version 1.6.1.Final of type io.debezium.connector.mongodb.MongoDbConnectorTask [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,410 INFO || JsonConverterConfig values:
connect_1 | converter.type = key
connect_1 | decimal.format = BASE64
connect_1 | schemas.cache.size = 1000
connect_1 | schemas.enable = true
connect_1 | [org.apache.kafka.connect.json.JsonConverterConfig]
connect_1 | 2021-08-16 07:28:05,411 INFO || Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task mongo-material-0 using the worker config [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,411 INFO || JsonConverterConfig values:
connect_1 | converter.type = value
connect_1 | decimal.format = BASE64
connect_1 | schemas.cache.size = 1000
connect_1 | schemas.enable = true
connect_1 | [org.apache.kafka.connect.json.JsonConverterConfig]
connect_1 | 2021-08-16 07:28:05,411 INFO || Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task mongo-material-0 using the worker config [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,411 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task mongo-material-0 using the worker config [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,418 INFO || SourceConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | topic.creation.groups = []
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.SourceConnectorConfig]
connect_1 | 2021-08-16 07:28:05,418 INFO || EnrichedConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | topic.creation.groups = []
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
connect_1 | 2021-08-16 07:28:05,422 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-16 07:28:05,424 INFO || ProducerConfig values:
connect_1 | acks = -1
connect_1 | batch.size = 16384
connect_1 | bootstrap.servers = [kafka:9092]
connect_1 | buffer.memory = 33554432
connect_1 | client.dns.lookup = use_all_dns_ips
connect_1 | client.id = connector-producer-mongo-material-0
connect_1 | compression.type = none
connect_1 | connections.max.idle.ms = 540000
connect_1 | delivery.timeout.ms = 2147483647
connect_1 | enable.idempotence = false
connect_1 | interceptor.classes = []
connect_1 | internal.auto.downgrade.txn.commit = false
connect_1 | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
connect_1 | linger.ms = 0
connect_1 | max.block.ms = 9223372036854775807
connect_1 | max.in.flight.requests.per.connection = 1
connect_1 | max.request.size = 1048576
connect_1 | metadata.max.age.ms = 300000
connect_1 | metadata.max.idle.ms = 300000
connect_1 | metric.reporters = []
connect_1 | metrics.num.samples = 2
connect_1 | metrics.recording.level = INFO
connect_1 | metrics.sample.window.ms = 30000
connect_1 | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
connect_1 | receive.buffer.bytes = 32768
connect_1 | reconnect.backoff.max.ms = 1000
connect_1 | reconnect.backoff.ms = 50
connect_1 | request.timeout.ms = 2147483647
connect_1 | retries = 2147483647
connect_1 | retry.backoff.ms = 100
connect_1 | sasl.client.callback.handler.class = null
connect_1 | sasl.jaas.config = null
connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
connect_1 | sasl.kerberos.min.time.before.relogin = 60000
connect_1 | sasl.kerberos.service.name = null
connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
connect_1 | sasl.login.callback.handler.class = null
connect_1 | sasl.login.class = null
connect_1 | sasl.login.refresh.buffer.seconds = 300
connect_1 | sasl.login.refresh.min.period.seconds = 60
connect_1 | sasl.login.refresh.window.factor = 0.8
connect_1 | sasl.login.refresh.window.jitter = 0.05
connect_1 | sasl.mechanism = GSSAPI
connect_1 | security.protocol = PLAINTEXT
connect_1 | security.providers = null
connect_1 | send.buffer.bytes = 131072
connect_1 | socket.connection.setup.timeout.max.ms = 127000
connect_1 | socket.connection.setup.timeout.ms = 10000
connect_1 | ssl.cipher.suites = null
connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
connect_1 | ssl.endpoint.identification.algorithm = https
connect_1 | ssl.engine.factory.class = null
connect_1 | ssl.key.password = null
connect_1 | ssl.keymanager.algorithm = SunX509
connect_1 | ssl.keystore.certificate.chain = null
connect_1 | ssl.keystore.key = null
connect_1 | ssl.keystore.location = null
connect_1 | ssl.keystore.password = null
connect_1 | ssl.keystore.type = JKS
connect_1 | ssl.protocol = TLSv1.3
connect_1 | ssl.provider = null
connect_1 | ssl.secure.random.implementation = null
connect_1 | ssl.trustmanager.algorithm = PKIX
connect_1 | ssl.truststore.certificates = null
connect_1 | ssl.truststore.location = null
connect_1 | ssl.truststore.password = null
connect_1 | ssl.truststore.type = JKS
connect_1 | transaction.timeout.ms = 60000
connect_1 | transactional.id = null
connect_1 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
connect_1 | [org.apache.kafka.clients.producer.ProducerConfig]
connect_1 | 2021-08-16 07:28:05,431 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
connect_1 | 2021-08-16 07:28:05,432 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
connect_1 | 2021-08-16 07:28:05,432 INFO || Kafka version: 2.7.0 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-16 07:28:05,432 INFO || Kafka commitId: 448719dc99a19793 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-16 07:28:05,432 INFO || Kafka startTimeMs: 1629098885432 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-16 07:28:05,437 INFO || [Producer clientId=connector-producer-mongo-material-0] Cluster ID: QUGIO_c7QP29LyR0F4WiDw [org.apache.kafka.clients.Metadata]
connect_1 | 2021-08-16 07:28:05,441 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
connect_1 | 2021-08-16 07:28:05,443 INFO || SourceConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | topic.creation.groups = []
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.SourceConnectorConfig]
connect_1 | 2021-08-16 07:28:05,443 INFO || EnrichedConnectorConfig values:
connect_1 | config.action.reload = restart
connect_1 | connector.class = io.debezium.connector.mongodb.MongoDbConnector
connect_1 | errors.log.enable = false
connect_1 | errors.log.include.messages = false
connect_1 | errors.retry.delay.max.ms = 60000
connect_1 | errors.retry.timeout = 0
connect_1 | errors.tolerance = none
connect_1 | header.converter = null
connect_1 | key.converter = null
connect_1 | name = mongo-material
connect_1 | predicates = []
connect_1 | tasks.max = 1
connect_1 | topic.creation.groups = []
connect_1 | transforms = []
connect_1 | value.converter = null
connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
connect_1 | 2021-08-16 07:28:05,443 INFO MongoDB|overseatestmongo1|conn Subdividing 1 MongoDB replica set(s) into at most 1 task(s)
[io.debezium.connector.mongodb.MongoDbConnector]
connect_1 | 2021-08-16 07:28:05,443 INFO MongoDB|overseatestmongo1|conn Configuring MongoDB connector task 0 to capture events for replica set(s) at overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020 [io.debezium.connector.mongodb.MongoDbConnector]
connect_1 | 2021-08-16 07:28:05,444 INFO || Starting MongoDbConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,449 INFO || connector.class = io.debezium.connector.mongodb.MongoDbConnector [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || mongodb.password = ******** [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || database.history.kafka.bootstrap.servers = kafka:9092 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || mongodb.user = dev [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || MongoDB.authsource = admin [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || mongodb.name = overseatestmongo1 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || snapshot.max.threads = 2 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,450 INFO || task.class = io.debezium.connector.mongodb.MongoDbConnectorTask [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,451 INFO || mongodb.task.id = 0 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,451 INFO || name = mongo-material [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,451 INFO || mongodb.hosts = overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,451 INFO || database.include.list = db_sky [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,451 INFO || snapshot.mode = initial [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-16 07:28:05,602 INFO MongoDB|overseatestmongo1|task0 Requested thread factory for connector MongoDbConnector, id = overseatestmongo1 named = change-event-source-coordinator [io.debezium.util.Threads]
connect_1 | 2021-08-16 07:28:05,605 INFO MongoDB|overseatestmongo1|task0 Creating thread debezium-mongodbconnector-overseatestmongo1-change-event-source-coordinator [io.debezium.util.Threads]
connect_1 | 2021-08-16 07:28:05,606 INFO || WorkerSourceTask{id=mongo-material-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask]
connect_1 | 2021-08-16 07:28:05,609 INFO MongoDB|overseatestmongo1|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-16 07:28:05,609 INFO MongoDB|overseatestmongo1|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-16 07:28:05,612 INFO MongoDB|overseatestmongo1|snapshot No previous offset has been found [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,612 INFO MongoDB|overseatestmongo1|snapshot Snapshot step 1 - Preparing [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,612 INFO MongoDB|overseatestmongo1|snapshot Snapshot step 2 - Determining snapshot offsets [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,612 INFO MongoDB|overseatestmongo1|snapshot Determine Snapshot Offset for replica-set overseatestmongo1 [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,614 INFO MongoDB|overseatestmongo1|snapshot Cluster created with settings {hosts=[10.130.84.24:10017, 10.130.84.32:10020], mode=MULTIPLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,614 INFO MongoDB|overseatestmongo1|snapshot Adding discovered server 10.130.84.24:10017 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,615 INFO MongoDB|overseatestmongo1|snapshot Adding discovered server 10.130.84.32:10020 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,617 INFO MongoDB|overseatestmongo1|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,630 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:10, serverValue:5500014}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,630 INFO MongoDB|overseatestmongo1|snapshot Monitor thread successfully connected to server with description ServerDescription{address=10.130.84.24:10017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=6435800, setName='overseatestmongo1', canonicalAddress=10.130.84.24:10017, hosts=[10.130.84.24:10017, 10.130.84.32:10020], passives=[], arbiters=[], primary='10.130.84.24:10017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000002, setVersion=206495, topologyVersion=null, lastWriteDate=Mon Aug 16 07:28:01 UTC 2021, lastUpdateTimeNanos=154306957808600} [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Discovered cluster type of REPLICA_SET [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Setting max election id to 7fffffff0000000000000002 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Setting max set version to 206495 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Discovered replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:12, serverValue:6103120}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,632 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:11, serverValue:5500013}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,631 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:13, serverValue:6103119}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,632 INFO MongoDB|overseatestmongo1|snapshot Monitor thread successfully connected to server with description ServerDescription{address=10.130.84.32:10020, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3720800, setName='overseatestmongo1', canonicalAddress=10.130.84.32:10020, hosts=[10.130.84.24:10017, 10.130.84.32:10020], passives=[], arbiters=[], primary='10.130.84.24:10017', tagSet=TagSet{[]}, electionId=null, setVersion=206495, topologyVersion=null, lastWriteDate=Mon Aug 16 07:28:01 UTC 2021, lastUpdateTimeNanos=154306958259000} [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,728 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:14, serverValue:5500015}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,734 INFO MongoDB|overseatestmongo1|snapshot Cluster created with settings {hosts=[10.130.84.24:10017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,741 INFO MongoDB|overseatestmongo1|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,745 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:16, serverValue:5500017}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,745 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:15, serverValue:5500016}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,746 INFO MongoDB|overseatestmongo1|snapshot Monitor thread successfully connected to server with description ServerDescription{address=10.130.84.24:10017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3532900, setName='overseatestmongo1', canonicalAddress=10.130.84.24:10017, hosts=[10.130.84.24:10017, 10.130.84.32:10020], passives=[], arbiters=[], primary='10.130.84.24:10017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000002, setVersion=206495, topologyVersion=null, lastWriteDate=Mon Aug 16 07:28:01 UTC 2021, lastUpdateTimeNanos=154307073184400} [org.mongodb.driver.cluster]
connect_1 | 2021-08-16 07:28:05,799 INFO MongoDB|overseatestmongo1|snapshot Opened connection [connectionId{localValue:17, serverValue:5500018}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,806 INFO MongoDB|overseatestmongo1|snapshot Stopping primary client [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,807 INFO MongoDB|overseatestmongo1|snapshot Requested thread factory for connector MongoDbConnector, id = overseatestmongo1 named = replicator-snapshot [io.debezium.util.Threads]
connect_1 | 2021-08-16 07:28:05,808 INFO MongoDB|overseatestmongo1|snapshot Ignoring unnamed replica sets: [] [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,808 INFO MongoDB|overseatestmongo1|snapshot Starting 1 thread(s) to snapshot replica sets: [overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020] [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,808 INFO MongoDB|overseatestmongo1|snapshot Snapshot step 3 - Snapshotting data [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,809 INFO MongoDB|overseatestmongo1|snapshot Creating thread debezium-mongodbconnector-overseatestmongo1-replicator-snapshot-0 [io.debezium.util.Threads]
connect_1 | 2021-08-16 07:28:05,810 INFO MongoDB|overseatestmongo1|overseatestmongo1 Beginning snapshot of 'overseatestmongo1' at {sec=1629098881, ord=5, initsync=true, h=-5011051939026255270, stxnid=null} [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,820 INFO MongoDB|overseatestmongo1|overseatestmongo1 Requested thread factory for connector MongoDbConnector, id = overseatestmongo1 named = snapshot-overseatestmongo1 [io.debezium.util.Threads]
connect_1 | 2021-08-16 07:28:05,820 INFO MongoDB|overseatestmongo1|overseatestmongo1 Preparing to use 0 thread(s) to snapshot 0 collection(s): [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,820 INFO MongoDB|overseatestmongo1|snapshot Stopping mongodb connections [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,820 INFO MongoDB|overseatestmongo1|snapshot Closing all connections to overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020 [io.debezium.connector.mongodb.ConnectionContext]
connect_1 | 2021-08-16 07:28:05,825 INFO MongoDB|overseatestmongo1|snapshot Closed connection [connectionId{localValue:17, serverValue:5500018}] to 10.130.84.24:10017 because the pool has been closed. [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,835 INFO MongoDB|overseatestmongo1|snapshot Closed connection [connectionId{localValue:14, serverValue:5500015}] to 10.130.84.24:10017 because the pool has been closed. [org.mongodb.driver.connection]
connect_1 | 2021-08-16 07:28:05,837 INFO MongoDB|overseatestmongo1|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource]
connect_1 | 2021-08-16 07:28:05,837 INFO MongoDB|overseatestmongo1|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=MongoDbOffsetContext [sourceInfo=io.debezium.connector.mongodb.SourceInfo@312e122]] [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-16 07:28:05,837 WARN MongoDB|overseatestmongo1|snapshot After applying the include/exclude list filters, no changes will be captured. Please check your configuration! [io.debezium.connector.mongodb.MongoDbSchema]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment