2022-01-20 06:00:19,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:00:49,858 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:00:49,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:01:19,933 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:01:49,860 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:01:49,938 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:02:19,930 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:02:49,860 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:02:49,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:03:19,933 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:03:49,861 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:03:49,930 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:04:19,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:04:49,861 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:04:49,933 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:05:19,937 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:05:49,862 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:05:49,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:06:19,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:06:49,862 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:06:49,935 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:07:19,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:07:49,863 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:07:49,930 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:08:19,932 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:08:49,864 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:08:49,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:09:19,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:09:49,864 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:09:49,933 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:10:19,938 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:10:49,865 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:10:49,931 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:10:50,695 INFO || Successfully processed removal of connector 'mongo-connector-1' [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-01-20 06:10:50,696 INFO || [Worker clientId=connect-1, groupId=1] Connector mongo-connector-1 config removed [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,699 INFO || [Worker clientId=connect-1, groupId=1] Handling connector-only config update by stopping connector mongo-connector-1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,699 INFO || Stopping connector mongo-connector-1 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:10:50,699 INFO || Scheduled shutdown for WorkerConnector{id=mongo-connector-1} [org.apache.kafka.connect.runtime.WorkerConnector] 2022-01-20 06:10:50,699 INFO MongoDB|mongo_1|conn Stopping MongoDB connector [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:10:50,699 INFO MongoDB|mongo_1|conn Closing all connections to rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ConnectionContext] 2022-01-20 06:10:50,704 INFO MongoDB|mongo_1|conn Stopped MongoDB connector [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:10:50,708 INFO || Completed shutdown for WorkerConnector{id=mongo-connector-1} [org.apache.kafka.connect.runtime.WorkerConnector] 2022-01-20 06:10:50,709 INFO || [Worker clientId=connect-1, groupId=1] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,709 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,719 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=8, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,726 INFO || [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=8, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,727 INFO || Stopping connector mongo-connector-1 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:10:50,727 WARN || Ignoring stop request for unowned connector mongo-connector-1 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:10:50,727 WARN || Ignoring await stop request for non-present connector mongo-connector-1 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:10:50,727 INFO || Stopping task mongo-connector-1-0 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:10:50,910 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:10:50,910 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:10:50,941 INFO MongoDB|mongo_1|streaming Closing all connections to replSet/10.123.234.31:31007 [io.debezium.connector.mongodb.ConnectionContext] 2022-01-20 06:10:50,948 INFO MongoDB|mongo_1|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-01-20 06:10:50,948 INFO MongoDB|mongo_1|streaming Connected metrics set to 'false' [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics] 2022-01-20 06:10:50,950 INFO || [Producer clientId=connector-producer-mongo-connector-1-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2022-01-20 06:10:50,954 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-01-20 06:10:50,955 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-01-20 06:10:50,955 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-01-20 06:10:50,955 INFO || App info kafka.producer for connector-producer-mongo-connector-1-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-01-20 06:10:50,970 INFO || [Worker clientId=connect-1, groupId=1] Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] Finished flushing status backing store in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] Joined group at generation 8 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', leaderUrl='http://172.17.0.4:8083/', offset=12, connectorIds=[], taskIds=[], revokedConnectorIds=[mongo-connector-1], revokedTaskIds=[mongo-connector-1-0], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 12 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,977 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,981 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=9, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,986 INFO || [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=9, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:10:50,986 INFO || [Worker clientId=connect-1, groupId=1] Joined group at generation 9 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', leaderUrl='http://172.17.0.4:8083/', offset=12, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,986 INFO || [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 12 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:10:50,986 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,300 INFO || Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,318 INFO || Opened connection [connectionId{localValue:16, serverValue:320373}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,318 INFO || Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=2745714, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254399883872830} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,319 INFO || Closing all connections to rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ConnectionContext] 2022-01-20 06:11:31,321 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2022-01-20 06:11:31,327 INFO || [Worker clientId=connect-1, groupId=1] Connector mongo-connector-1 config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,332 INFO || [Worker clientId=connect-1, groupId=1] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,332 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,337 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=10, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,343 INFO || [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=10, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,343 INFO || [Worker clientId=connect-1, groupId=1] Joined group at generation 10 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', leaderUrl='http://172.17.0.4:8083/', offset=13, connectorIds=[mongo-connector-1], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,343 INFO || [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 13 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,348 INFO || [Worker clientId=connect-1, groupId=1] Starting connector mongo-connector-1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,348 INFO || Creating connector mongo-connector-1 of type io.debezium.connector.mongodb.MongoDbConnector [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,348 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-01-20 06:11:31,348 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-01-20 06:11:31,349 INFO || Instantiated connector mongo-connector-1 with version 1.8.0.Final of type class io.debezium.connector.mongodb.MongoDbConnector [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,349 INFO || Finished creating connector mongo-connector-1 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,350 INFO MongoDB|mongo_1|conn Starting MongoDB connector and discovering replica set(s) at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,350 INFO MongoDB|mongo_1|conn Requested thread factory for connector MongoDbConnector, id = mongo_1 named = replica-set-monitor [io.debezium.util.Threads] 2022-01-20 06:11:31,350 INFO MongoDB|mongo_1|conn Creating thread debezium-mongodbconnector-mongo_1-replica-set-monitor [io.debezium.util.Threads] 2022-01-20 06:11:31,350 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,354 INFO MongoDB|mongo_1|conn Successfully started MongoDB connector, and continuing to discover changes in replica set(s) at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,355 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-01-20 06:11:31,355 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-01-20 06:11:31,355 INFO MongoDB|mongo_1|disc Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,366 INFO MongoDB|mongo_1|disc Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster] 2022-01-20 06:11:31,369 INFO MongoDB|mongo_1|disc Opened connection [connectionId{localValue:17, serverValue:320374}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,369 INFO MongoDB|mongo_1|disc Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3045315, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254399935340784} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,375 INFO MongoDB|mongo_1|disc Opened connection [connectionId{localValue:18, serverValue:320375}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,400 INFO MongoDB|mongo_1|disc Opened connection [connectionId{localValue:19, serverValue:320376}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|disc Requesting task reconfiguration due to new/removed replica set(s) for MongoDB with seeds rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|disc New replica sets include: [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|disc replSet/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|conn Subdividing 1 MongoDB replica set(s) into at most 1 task(s) [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,409 INFO MongoDB|mongo_1|conn Configuring MongoDB connector task 0 to capture events for replica set(s) at replSet/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,442 INFO || [Worker clientId=connect-1, groupId=1] Tasks [mongo-connector-1-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,448 INFO || [Worker clientId=connect-1, groupId=1] Handling task config update by restarting tasks [] [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,448 INFO || [Worker clientId=connect-1, groupId=1] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,448 INFO || [Worker clientId=connect-1, groupId=1] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,449 INFO || [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=11, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,451 INFO || [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=11, memberId='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-01-20 06:11:31,452 INFO || [Worker clientId=connect-1, groupId=1] Joined group at generation 11 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-3f5c378e-897c-444f-b237-290cc786afb6', leaderUrl='http://172.17.0.4:8083/', offset=15, connectorIds=[mongo-connector-1], taskIds=[mongo-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,452 INFO || [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 15 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,452 INFO || [Worker clientId=connect-1, groupId=1] Starting task mongo-connector-1-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,452 INFO || Creating task mongo-connector-1-0 [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,452 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig] 2022-01-20 06:11:31,452 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-01-20 06:11:31,453 INFO || TaskConfig values: task.class = class io.debezium.connector.mongodb.MongoDbConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2022-01-20 06:11:31,453 INFO || Instantiated task mongo-connector-1-0 with version 1.8.0.Final of type io.debezium.connector.mongodb.MongoDbConnectorTask [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,453 INFO || JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2022-01-20 06:11:31,453 INFO || Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task mongo-connector-1-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,453 INFO || JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2022-01-20 06:11:31,453 INFO || Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task mongo-connector-1-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,453 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task mongo-connector-1-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,454 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-01-20 06:11:31,454 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-01-20 06:11:31,454 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2022-01-20 06:11:31,454 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-mongo-connector-1-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null 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 transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2022-01-20 06:11:31,471 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-01-20 06:11:31,471 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-01-20 06:11:31,471 INFO || Kafka version: 3.0.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-01-20 06:11:31,471 INFO || Kafka commitId: 8cb0a5e9d3441962 [org.apache.kafka.common.utils.AppInfoParser] 2022-01-20 06:11:31,471 INFO || Kafka startTimeMs: 1642659091471 [org.apache.kafka.common.utils.AppInfoParser] 2022-01-20 06:11:31,472 INFO || [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-01-20 06:11:31,472 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-01-20 06:11:31,472 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mongo-connector-1 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-01-20 06:11:31,472 INFO MongoDB|mongo_1|conn Subdividing 1 MongoDB replica set(s) into at most 1 task(s) [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,472 INFO MongoDB|mongo_1|conn Configuring MongoDB connector task 0 to capture events for replica set(s) at replSet/10.123.234.31:31007 [io.debezium.connector.mongodb.MongoDbConnector] 2022-01-20 06:11:31,478 INFO || Starting MongoDbConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || connector.class = io.debezium.connector.mongodb.MongoDbConnector [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || task.class = io.debezium.connector.mongodb.MongoDbConnectorTask [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || mongodb.password = ******** [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || mongodb.task.id = 0 [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || mongodb.user = root [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || name = mongo-connector-1 [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || mongodb.name = mongo_1 [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || mongodb.hosts = replSet/10.123.234.31:31007 [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,479 INFO || database.include.list = kenyon_test2,kenyon_text [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:31,510 INFO || Found previous offsets MongoDbOffsetContext [sourceInfo=io.debezium.connector.mongodb.SourceInfo@2e668b64] [io.debezium.connector.mongodb.MongoDbConnectorTask] 2022-01-20 06:11:31,510 INFO MongoDB|mongo_1|task0 Requested thread factory for connector MongoDbConnector, id = mongo_1 named = change-event-source-coordinator [io.debezium.util.Threads] 2022-01-20 06:11:31,510 INFO MongoDB|mongo_1|task0 Creating thread debezium-mongodbconnector-mongo_1-change-event-source-coordinator [io.debezium.util.Threads] 2022-01-20 06:11:31,512 INFO || [Producer clientId=connector-producer-mongo-connector-1-0] Cluster ID: 8XrAM8veSumJENonAW_U0g [org.apache.kafka.clients.Metadata] 2022-01-20 06:11:31,516 INFO || WorkerSourceTask{id=mongo-connector-1-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:11:31,516 INFO MongoDB|mongo_1|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-01-20 06:11:31,516 INFO MongoDB|mongo_1|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-01-20 06:11:31,516 INFO MongoDB|mongo_1|snapshot Found existing offset for replica set 'replSet' at {sec=1642658190, ord=1, lsid=null, transaction_id=null, resume_token=8261E8F98E000000012B022C0100296E5A1004AD063E90E943405CBE405900547E04EE46645F6964006461DB9ABAB44B6B047D6D10A80004, h=0, txnNumber=0} [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource] 2022-01-20 06:11:31,516 INFO MongoDB|mongo_1|snapshot Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,520 INFO MongoDB|mongo_1|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster] 2022-01-20 06:11:31,525 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:20, serverValue:320377}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,525 INFO MongoDB|mongo_1|snapshot Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=4991825, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254400091232855} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,528 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:21, serverValue:320378}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,544 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:22, serverValue:320379}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,546 INFO MongoDB|mongo_1|snapshot Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,550 INFO MongoDB|mongo_1|snapshot Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster] 2022-01-20 06:11:31,554 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:23, serverValue:320380}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,554 INFO MongoDB|mongo_1|snapshot Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=4501522, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254400120443399} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,555 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:24, serverValue:320381}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,587 INFO MongoDB|mongo_1|snapshot Opened connection [connectionId{localValue:25, serverValue:320382}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,590 INFO MongoDB|mongo_1|snapshot The oplog contains the last entry previously read for 'replSet', so no snapshot will be performed [io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource] 2022-01-20 06:11:31,590 INFO MongoDB|mongo_1|snapshot Closing all connections to replSet/10.123.234.31:31007 [io.debezium.connector.mongodb.ConnectionContext] 2022-01-20 06:11:31,595 INFO MongoDB|mongo_1|snapshot Snapshot ended with SnapshotResult [status=SKIPPED, offset=MongoDbOffsetContext [sourceInfo=io.debezium.connector.mongodb.SourceInfo@2e668b64]] [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-01-20 06:11:31,596 INFO MongoDB|mongo_1|streaming Connected metrics set to 'true' [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics] 2022-01-20 06:11:31,596 INFO MongoDB|mongo_1|streaming No incremental snapshot in progress, no action needed on start [io.debezium.connector.mongodb.MongoDbIncrementalSnapshotChangeEventSource] 2022-01-20 06:11:31,596 INFO MongoDB|mongo_1|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-01-20 06:11:31,596 INFO MongoDB|mongo_1|streaming Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,597 INFO MongoDB|mongo_1|streaming Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster] 2022-01-20 06:11:31,601 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:26, serverValue:320383}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,601 INFO MongoDB|mongo_1|streaming Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3165116, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254400167217230} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,607 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:27, serverValue:320384}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,631 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:28, serverValue:320385}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,636 INFO MongoDB|mongo_1|streaming Cluster created with settings {hosts=[10.123.234.31:31007], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,639 INFO MongoDB|mongo_1|streaming Cluster description not yet available. Waiting for 30000 ms before timing out [org.mongodb.driver.cluster] 2022-01-20 06:11:31,641 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:29, serverValue:320386}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,641 INFO MongoDB|mongo_1|streaming Monitor thread successfully connected to server with description ServerDescription{address=10.123.234.31:31007, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=1721408, setName='replSet', canonicalAddress=mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017, hosts=[mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017], passives=[], arbiters=[], primary='mongodb-0.mongodb-headless.cloudladder-mongodb.svc.cluster.local:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000005, setVersion=1, topologyVersion=TopologyVersion{processId=61dcf682ffa6ff9820e2eff1, counter=6}, lastWriteDate=Thu Jan 20 06:11:27 GMT 2022, lastUpdateTimeNanos=254400206983026} [org.mongodb.driver.cluster] 2022-01-20 06:11:31,643 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:30, serverValue:320387}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,657 INFO MongoDB|mongo_1|streaming Opened connection [connectionId{localValue:31, serverValue:320388}] to 10.123.234.31:31007 [org.mongodb.driver.connection] 2022-01-20 06:11:31,659 INFO MongoDB|mongo_1|streaming Reading change stream for 'replSet/10.123.234.31:31007' primary 10.123.234.31:31007 starting at Timestamp{value=7055163204556554241, seconds=1642658190, inc=1} [io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource] 2022-01-20 06:11:31,660 INFO MongoDB|mongo_1|streaming Resuming streaming from token '8261E8F98E000000012B022C0100296E5A1004AD063E90E943405CBE405900547E04EE46645F6964006461DB9ABAB44B6B047D6D10A80004' [io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource] 2022-01-20 06:11:40,563 INFO || 1 records sent during previous 00:00:09.109, last recorded offset: {sec=1642659100, ord=1, transaction_id=null, resume_token=8261E8FD1C000000012B022C0100296E5A1004AD063E90E943405CBE405900547E04EE46645F6964006461DB9ABAB44B6B047D6D10A80004, h=null} [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:11:47,076 INFO || 1 records sent during previous 00:00:06.513, last recorded offset: {sec=1642659106, ord=1, transaction_id=null, resume_token=8261E8FD22000000012B022C0100296E5A1004AD063E90E943405CBE405900547E04EE46645F6964006461DB9ABAB44B6B047D6D10A80004, h=null} [io.debezium.connector.common.BaseSourceTask] 2022-01-20 06:12:01,355 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:12:31,352 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery] 2022-01-20 06:12:31,472 INFO || WorkerSourceTask{id=mongo-connector-1-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-01-20 06:13:01,355 INFO MongoDB|mongo_1|disc Checking current members of replica set at rs0/10.123.234.31:31007 [io.debezium.connector.mongodb.ReplicaSetDiscovery]