Skip to content

Instantly share code, notes, and snippets.

@zhiyue

zhiyue/logs.txt

Created August 13, 2021 10:10
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save zhiyue/0230830edb9b07b520152fc30d0f42d8 to your computer and use it in GitHub Desktop.
Save zhiyue/0230830edb9b07b520152fc30d0f42d8 to your computer and use it in GitHub Desktop.
Download ZIP
debezium logs
Raw
logs.txt
connect_1 | 2021-08-13 09:06:08,829 INFO || [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=3,
memberId='connect-1-a15bceef-df8b-4325-85c0-6ae6a058401a', protocol='sessioned'} [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
connect_1 | 2021-08-13 09:06:08,829 INFO || [Worker clientId=connect-1, groupId=1] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-a15bceef-df8b-4325-85c0-6ae6a058401a', leaderUrl='http://172.18.0.2:8083/', offset=4, connectorIds=[mongo-material], taskIds=[mongo-material-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
connect_1 | 2021-08-13 09:06:08,831 INFO || [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 4 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
connect_1 | 2021-08-13 09:06:08,832 INFO || [Worker clientId=connect-1, groupId=1] Starting task mongo-material-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
connect_1 | 2021-08-13 09:06:08,832 INFO || Creating task mongo-material-0 [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-13 09:06:08,834 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-13 09:06:08,834 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-13 09:06:08,836 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-13 09:06:08,837 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-13 09:06:08,838 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-13 09:06:08,838 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-13 09:06:08,838 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-13 09:06:08,839 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-13 09:06:08,839 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-13 09:06:08,848 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-13 09:06:08,849 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-13 09:06:08,852 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker]
connect_1 | 2021-08-13 09:06:08,854 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-13 09:06:08,876 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-13 09:06:08,876 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-13 09:06:08,876 INFO || Kafka version: 2.7.0 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-13 09:06:08,876 INFO || Kafka commitId: 448719dc99a19793 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-13 09:06:08,876 INFO || Kafka startTimeMs: 1628845568876 [org.apache.kafka.common.utils.AppInfoParser]
connect_1 | 2021-08-13 09:06:08,897 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
connect_1 | 2021-08-13 09:06:08,897 INFO || [Producer clientId=connector-producer-mongo-material-0] Cluster ID: 0NqT4ep-QsqRiQ0CTNDskw [org.apache.kafka.clients.Metadata]
connect_1 | 2021-08-13 09:06:08,903 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-13 09:06:08,903 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-13 09:06:08,903 INFO MongoDB|test|conn Subdividing 1 MongoDB replica set(s) into at most 1 task(s) [io.debezium.connector.mongodb.MongoDbConnector]
connect_1 | 2021-08-13 09:06:08,903 INFO MongoDB|test|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-13 09:06:08,905 INFO || Starting MongoDbConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,907 INFO || connector.class = io.debezium.connector.mongodb.MongoDbConnector [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || snapshot.include.collection.list = db_sky.material [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || collection.include.list = db_sky.material [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || mongodb.password = ******** [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || database.history.kafka.bootstrap.servers = kafka:9092 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || mongodb.user = dev [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || MongoDB.authsource = admin [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || mongodb.name = test [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,908 INFO || snapshot.max.threads = 2 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,910 INFO || task.class = io.debezium.connector.mongodb.MongoDbConnectorTask [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,911 INFO || mongodb.task.id = 0 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,911 INFO || name = mongo-material [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,911 INFO || mongodb.hosts = overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020 [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,911 INFO || database.include.list = db_sky [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:08,911 INFO || snapshot.mode = initial [io.debezium.connector.common.BaseSourceTask]
connect_1 | 2021-08-13 09:06:09,205 INFO MongoDB|test|task0 Requested thread factory for connector MongoDbConnector, id = test named = change-event-source-coordinator [io.debezium.util.Threads]
connect_1 | 2021-08-13 09:06:09,207 INFO MongoDB|test|task0 Creating thread debezium-mongodbconnector-test-change-event-source-coordinator [io.debezium.util.Threads]
connect_1 | 2021-08-13 09:06:09,208 INFO || WorkerSourceTask{id=mongo-material-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask]
connect_1 | 2021-08-13 09:06:09,209 INFO MongoDB|test|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-13 09:06:09,210 INFO MongoDB|test|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-13 09:06:09,213 INFO MongoDB|test|snapshot No previous offset has been found [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,213 INFO MongoDB|test|snapshot Snapshot step 1 - Preparing [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,213 INFO MongoDB|test|snapshot Snapshot step 2 - Determining snapshot offsets [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,213 INFO MongoDB|test|snapshot Determine Snapshot Offset for replica-set overseatestmongo1 [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,216 INFO MongoDB|test|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-13 09:06:09,216 INFO MongoDB|test|snapshot Adding discovered server 10.130.84.24:10017 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,227 INFO MongoDB|test|snapshot Adding discovered server 10.130.84.32:10020 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,230 INFO MongoDB|test|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,343 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:11, serverValue:5956397}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,343 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:10, serverValue:5365568}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,343 INFO MongoDB|test|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=72781200, 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=Fri Aug 13 09:06:07 UTC 2021, lastUpdateTimeNanos=647563509791600} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,343 INFO MongoDB|test|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=51603000, 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=Fri Aug 13 09:06:07 UTC 2021, lastUpdateTimeNanos=647563494133400} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,343 INFO MongoDB|test|snapshot Discovered cluster type of REPLICA_SET [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,344 INFO MongoDB|test|snapshot Setting max election id to 7fffffff0000000000000002 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,344 INFO MongoDB|test|snapshot Setting max set version to 206495 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,344 INFO MongoDB|test|snapshot Discovered replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,363 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:12, serverValue:5365569}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,364 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:13, serverValue:5956398}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,441 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:14, serverValue:5365570}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,454 INFO MongoDB|test|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-13 09:06:09,476 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:15, serverValue:5365571}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,479 INFO MongoDB|test|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,480 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:16, serverValue:5365572}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,480 INFO MongoDB|test|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=8875100, 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=Fri Aug 13 09:06:07 UTC 2021, lastUpdateTimeNanos=647563687279600} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,574 INFO MongoDB|test|snapshot Opened connection [connectionId{localValue:17, serverValue:5365573}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,593 INFO MongoDB|test|snapshot Stopping primary client [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,599 INFO MongoDB|test|snapshot Requested thread factory for connector MongoDbConnector, id = test named = replicator-snapshot [io.debezium.util.Threads]
connect_1 | 2021-08-13 09:06:09,600 INFO MongoDB|test|snapshot Ignoring unnamed replica sets: [] [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,600 INFO MongoDB|test|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-13 09:06:09,600 INFO MongoDB|test|snapshot Snapshot step 3 - Snapshotting data [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,606 INFO MongoDB|test|snapshot Creating thread debezium-mongodbconnector-test-replicator-snapshot-0 [io.debezium.util.Threads]
connect_1 | 2021-08-13 09:06:09,612 INFO MongoDB|test|overseatestmongo1 Beginning snapshot of 'overseatestmongo1' at {sec=1628845568, ord=5, initsync=true, h=-562375266479423623, stxnid=null} [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,627 INFO MongoDB|test|overseatestmongo1 Requested thread factory for connector MongoDbConnector, id = test named = snapshot-overseatestmongo1 [io.debezium.util.Threads]
connect_1 | 2021-08-13 09:06:09,628 INFO MongoDB|test|overseatestmongo1 Preparing to use 0 thread(s) to snapshot 0 collection(s): [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,628 INFO MongoDB|test|snapshot Stopping mongodb connections [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,629 INFO MongoDB|test|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-13 09:06:09,637 INFO MongoDB|test|snapshot Closed connection [connectionId{localValue:17, serverValue:5365573}] to 10.130.84.24:10017 because the pool has been closed. [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,648 INFO MongoDB|test|snapshot Closed connection [connectionId{localValue:14, serverValue:5365570}] to 10.130.84.24:10017 because the pool has been closed. [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,652 INFO MongoDB|test|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource]
connect_1 | 2021-08-13 09:06:09,652 INFO MongoDB|test|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=MongoDbOffsetContext [sourceInfo=io.debezium.connector.mongodb.SourceInfo@36b9724]] [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-13 09:06:09,652 WARN MongoDB|test|snapshot After applying the include/exclude list filters, no changes will be captured. Please check your configuration! [io.debezium.connector.mongodb.MongoDbSchema]
connect_1 | 2021-08-13 09:06:09,657 INFO MongoDB|test|streaming Connected metrics set to 'true' [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
connect_1 | 2021-08-13 09:06:09,657 INFO MongoDB|test|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator]
connect_1 | 2021-08-13 09:06:09,660 INFO MongoDB|test|streaming 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-13 09:06:09,660 INFO MongoDB|test|streaming Adding discovered server 10.130.84.24:10017 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,661 INFO MongoDB|test|streaming Adding discovered server 10.130.84.32:10020 to client view of cluster [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,663 INFO MongoDB|test|streaming Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,674 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:20, serverValue:5956400}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,675 INFO MongoDB|test|streaming 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=4380700, 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=Fri Aug 13 09:06:08 UTC 2021, lastUpdateTimeNanos=647563881482600} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,678 INFO MongoDB|test|streaming Discovered cluster type of REPLICA_SET [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,681 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:19, serverValue:5365575}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,685 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:18, serverValue:5365574}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,685 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:21, serverValue:5956399}] to 10.130.84.32:10020 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,689 INFO MongoDB|test|streaming 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=6719300, 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=Fri Aug 13 09:06:08 UTC 2021, lastUpdateTimeNanos=647563885671300} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,691 INFO MongoDB|test|streaming Setting max election id to 7fffffff0000000000000002 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,692 INFO MongoDB|test|streaming No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster
description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=10.130.84.32:10020, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=4380700, 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=Fri Aug 13 09:06:08 UTC 2021, lastUpdateTimeNanos=647563881482600}, ServerDescription{address=10.130.84.24:10017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,692 INFO MongoDB|test|streaming Setting max set version to 206495 from replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,692 INFO MongoDB|test|streaming Discovered replica set primary 10.130.84.24:10017 [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,748 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:22, serverValue:5365576}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,756 INFO MongoDB|test|streaming 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-13 09:06:09,759 INFO MongoDB|test|streaming Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,771 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:23, serverValue:5365577}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,771 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:24, serverValue:5365578}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,772 INFO MongoDB|test|streaming 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=3523200, 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=Fri Aug 13 09:06:08 UTC 2021, lastUpdateTimeNanos=647563976453400} [org.mongodb.driver.cluster]
connect_1 | 2021-08-13 09:06:09,824 INFO MongoDB|test|streaming Opened connection [connectionId{localValue:25, serverValue:5365579}] to 10.130.84.24:10017 [org.mongodb.driver.connection]
connect_1 | 2021-08-13 09:06:09,828 INFO MongoDB|test|streaming Reading oplog for 'overseatestmongo1/10.130.84.24:10017,10.130.84.32:10020' primary 10.130.84.24:10017 starting at Timestamp{value=6995838444794544133, seconds=1628845568, inc=5} [io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment