2020-09-08 10:54:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:54:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:55:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:55:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:55:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:55:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:56:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:56:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:56:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:56:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:57:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:57:34,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,133 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,232 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,232 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,233 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,233 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,335 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,351 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-6d42751c-9173-43fb-a8ea-8ce220c42c51 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,351 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,351 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:34,356 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:57:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:57:37,364 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 10:57:37,364 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-ace80494-5714-4889-9939-3098b02d9e2a', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 10:57:37,364 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 10:57:37,364 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 10:57:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:58:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:58:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:58:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:58:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:59:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 10:59:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:59:35,059 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 10:59:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:00:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:00:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:00:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:00:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:01:04,373 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-ace80494-5714-4889-9939-3098b02d9e2a is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:01:04,373 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:01:04,373 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:01:04,374 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:01:07,383 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:01:07,383 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-abc8897f-ad43-4445-a611-a305ba11ad70', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:01:07,383 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:01:07,383 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:01:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:01:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:01:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:01:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:02:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:02:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:02:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:02:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:03:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:03:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:03:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:03:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:04:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:04:34,395 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,395 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,425 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,506 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-abc8897f-ad43-4445-a611-a305ba11ad70 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,506 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,506 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:34,506 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:04:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:04:37,516 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:04:37,516 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-077b6c7e-a642-4a0a-beab-6b628a02907b', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:04:37,516 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:04:37,516 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:04:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:05:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:05:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:05:35,060 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:05:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:06:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:06:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:06:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:06:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:07:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:07:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:07:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:07:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:08:04,529 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,529 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,543 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,543 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,724 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,739 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-077b6c7e-a642-4a0a-beab-6b628a02907b is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,739 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,739 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:04,740 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:07,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:08:07,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0410aeae-9411-4c4c-bc5b-44e062874d3b', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:08:07,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:08:07,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:08:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:08:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:08:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:08:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:09:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:09:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:09:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:09:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:10:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:10:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:10:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:10:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:11:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:11:34,760 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,760 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,761 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,862 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-0410aeae-9411-4c4c-bc5b-44e062874d3b is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,862 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,862 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:34,863 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:11:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:11:37,871 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:11:37,871 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d49cdc05-e6ee-4985-897c-3d8b9df2a005', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:11:37,871 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:11:37,871 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:11:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:12:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:12:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:12:35,061 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:12:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:13:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:13:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:13:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:13:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:14:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:14:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:14:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:14:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:15:04,881 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,881 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,883 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,982 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-d49cdc05-e6ee-4985-897c-3d8b9df2a005 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,982 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,982 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:04,983 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:07,990 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:15:07,990 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-450a08bb-5316-4937-9682-b4cbc2fdb610', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:15:07,990 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:15:07,990 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:15:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:15:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:15:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:15:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:16:23,856 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:16:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:16:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:16:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:17:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:17:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:17:35,062 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:17:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:18:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:18:35,000 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-450a08bb-5316-4937-9682-b4cbc2fdb610 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:18:35,000 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:18:35,000 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:18:35,001 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:18:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:18:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:18:38,007 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:18:38,007 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-dd514938-c676-4baf-a244-72734ca2c520', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:18:38,007 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:18:38,007 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:18:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:19:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:19:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:19:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:19:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:20:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:20:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:20:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:20:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:21:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:21:35,063 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:21:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:21:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:22:05,021 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,021 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,039 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,133 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,133 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,134 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,134 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,236 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,249 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-dd514938-c676-4baf-a244-72734ca2c520 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,249 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,249 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:05,250 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:08,257 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:22:08,257 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-8abe8f58-1caf-440c-a992-1be075eaf836', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:22:08,257 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:22:08,257 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:22:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:22:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:22:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:22:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:23:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:23:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:23:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:23:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:24:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:24:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:24:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:24:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:25:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:25:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:25:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:25:35,275 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-8abe8f58-1caf-440c-a992-1be075eaf836 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:25:35,275 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:25:35,275 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:25:35,277 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:25:38,284 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:25:38,284 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-8b6abda4-940a-4b45-9e3f-6874a9b3840a', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:25:38,284 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:25:38,285 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:25:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:26:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:26:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:26:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:26:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:27:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:27:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:27:35,064 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:27:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:28:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:28:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:28:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:28:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:29:05,321 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,321 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,337 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-8b6abda4-940a-4b45-9e3f-6874a9b3840a is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:05,423 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:08,430 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:29:08,430 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-5b1f7b68-dc40-454d-b728-c19cbef43d3a', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:29:08,430 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:29:08,430 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:29:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:29:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:29:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:29:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:30:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:30:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:30:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:30:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:31:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:31:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:31:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:31:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:32:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:32:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:32:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:32:35,497 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,497 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,603 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,624 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-5b1f7b68-dc40-454d-b728-c19cbef43d3a is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,624 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,624 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:35,625 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:38,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:32:38,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-9f508610-21bc-4824-9666-a7ec8ffaddb5', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:32:38,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:32:38,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:32:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:33:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:33:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:33:35,065 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:33:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:34:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:34:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:34:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:34:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:35:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:35:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:35:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:35:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:36:05,647 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,647 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,648 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-9f508610-21bc-4824-9666-a7ec8ffaddb5 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,748 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:05,749 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:08,756 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:36:08,756 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-1fa230f0-b384-4179-8e65-702aa21b97fa', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:36:08,756 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:36:08,756 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:36:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:36:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:36:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:36:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:37:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:37:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:37:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:37:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:38:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:38:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:38:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:38:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:39:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:39:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:39:35,066 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:39:35,768 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,768 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,874 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,893 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-1fa230f0-b384-4179-8e65-702aa21b97fa is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,893 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,893 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:35,898 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:38,906 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:39:38,906 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-1a8d5e86-d50d-4f14-9d46-a38470bf40f0', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:39:38,907 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:39:38,907 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:39:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:40:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:40:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:40:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:40:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:41:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:41:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:41:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:41:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:42:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:42:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:42:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:42:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:43:05,921 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:05,921 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:06,028 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:06,045 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-1a8d5e86-d50d-4f14-9d46-a38470bf40f0 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:06,045 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:06,045 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:06,046 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:09,054 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:43:09,055 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-c3d4d374-6208-48ae-a6f6-647ad73df887', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:43:09,055 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:43:09,055 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:43:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:43:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:43:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:43:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:44:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:44:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:44:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:44:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:45:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:45:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:45:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:45:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:46:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:46:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:46:35,067 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:46:36,068 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,068 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,069 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,169 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-c3d4d374-6208-48ae-a6f6-647ad73df887 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:36,171 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:39,178 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:46:39,178 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-5027273e-9b5b-42c3-9919-b5f57b991f2a', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:46:39,178 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:46:39,178 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:46:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:47:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:47:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:47:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:47:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:48:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:48:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:48:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:48:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:49:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:49:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:49:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:49:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:50:06,194 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,194 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,325 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,347 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-5027273e-9b5b-42c3-9919-b5f57b991f2a is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,347 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,347 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:06,348 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:09,356 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:50:09,356 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-82e8a7b1-3013-4782-a2ac-028b7e717069', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:50:09,356 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:50:09,356 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:50:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:50:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:50:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:50:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:51:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:51:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:51:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:51:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:52:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:52:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:52:35,068 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:52:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:53:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:53:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:53:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:53:36,366 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-82e8a7b1-3013-4782-a2ac-028b7e717069 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:53:36,366 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:53:36,366 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:53:36,367 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:53:39,374 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:53:39,374 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-6ecccbf5-5536-4ed4-9b90-376da259e6cf', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:53:39,374 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:53:39,374 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:53:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:54:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:54:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:54:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:54:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:55:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:55:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:55:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:55:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:56:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:56:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:56:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:56:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:57:06,397 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,397 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,615 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-6ecccbf5-5536-4ed4-9b90-376da259e6cf is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,633 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:06,634 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:09,643 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 11:57:09,643 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-eede1798-fc94-4720-8291-339f9f14aa47', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:57:09,643 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:57:09,643 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 11:57:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:57:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:57:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:57:53,856 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:58:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:58:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:58:35,069 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:58:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:59:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 11:59:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:59:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 11:59:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:00:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:00:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:00:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:00:36,661 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,661 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,663 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,762 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,762 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,764 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,764 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,865 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,876 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-eede1798-fc94-4720-8291-339f9f14aa47 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,876 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,876 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:36,876 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:39,884 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:00:39,884 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-2162b90e-7d21-49aa-9ed1-c2b3e0b31738', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:00:39,884 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:00:39,884 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:00:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:01:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:01:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:01:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:01:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:02:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:02:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:02:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:02:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:03:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:03:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:03:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:03:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:04:06,929 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:06,929 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:06,931 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:07,030 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-2162b90e-7d21-49aa-9ed1-c2b3e0b31738 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:07,030 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:07,030 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:07,032 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:10,042 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:04:10,042 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-861cade2-4861-4fcd-a79d-1794f2746548', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:04:10,042 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:04:10,042 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:04:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:04:35,070 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:04:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:04:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:05:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:05:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:05:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:05:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:06:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:06:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:06:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:06:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:07:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:07:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:07:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:07:37,059 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,059 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,060 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,160 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-861cade2-4861-4fcd-a79d-1794f2746548 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,160 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,160 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:37,161 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:40,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:07:40,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0294cc64-913c-4f76-8a0c-baf359c8cd0b', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:07:40,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:07:40,170 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:07:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:08:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:08:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:08:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:08:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:09:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:09:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:09:35,071 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:09:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:10:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:10:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:10:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:10:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:11:07,184 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,184 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,186 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,286 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-0294cc64-913c-4f76-8a0c-baf359c8cd0b is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,286 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,286 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:07,287 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:10,296 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:11:10,296 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-a05211d2-395e-42bf-939c-05e3d4546489', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:11:10,296 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:11:10,296 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:11:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:11:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:11:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:11:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:12:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:12:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:12:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:12:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:13:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:13:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:13:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:13:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:14:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:14:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:14:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:14:37,320 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,320 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,333 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-a05211d2-395e-42bf-939c-05e3d4546489 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:37,423 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:40,432 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:14:40,432 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-9c03ca02-ffeb-4681-86ed-4c9a8d571edb', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:14:40,432 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:14:40,432 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:14:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:15:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:15:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:15:35,072 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:15:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:16:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:16:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:16:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:16:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:17:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:17:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:17:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:17:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:18:07,445 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,445 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,446 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,546 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-9c03ca02-ffeb-4681-86ed-4c9a8d571edb is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,546 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,546 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:07,547 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:10,553 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:18:10,553 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-b2ea9c02-1275-4d4a-aa5f-bf7a983827d5', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:18:10,553 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:18:10,554 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:18:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:18:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:18:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:18:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:19:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:19:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:19:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:19:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:20:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:20:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:20:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:20:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:21:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:21:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:21:35,073 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:21:37,567 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,567 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,741 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,760 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-b2ea9c02-1275-4d4a-aa5f-bf7a983827d5 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,760 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,760 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:37,761 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:40,769 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:21:40,769 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-c024aea5-6c48-40a3-9002-2368858fac7f', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:21:40,769 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:21:40,769 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:21:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:22:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:22:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:22:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:22:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:23:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:23:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:23:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:23:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:24:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:24:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:24:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:24:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:25:07,779 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,779 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,780 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,880 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-c024aea5-6c48-40a3-9002-2368858fac7f is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,880 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,880 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:07,882 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:10,890 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:25:10,890 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-24abf5a1-967a-4d1e-81d0-c11f2b67b2e8', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:25:10,890 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:25:10,890 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:25:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:25:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:25:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:25:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:26:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:26:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:26:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:26:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:27:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:27:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:27:35,074 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:27:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:28:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:28:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:28:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:28:37,903 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:37,903 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:37,904 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:38,004 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-24abf5a1-967a-4d1e-81d0-c11f2b67b2e8 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:38,004 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:38,004 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:38,004 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:41,013 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:28:41,013 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0e62aed3-bd4b-44ab-8acf-6ccdaa899c0b', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:28:41,013 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:28:41,013 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:28:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:29:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:29:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:29:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:29:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:30:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:30:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:30:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:30:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:31:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:31:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:31:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:31:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:32:08,021 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,021 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,022 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,122 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-0e62aed3-bd4b-44ab-8acf-6ccdaa899c0b is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,122 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,122 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:08,123 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:11,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:32:11,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-36c7fd73-b420-4ce3-89b0-92694e5182fa', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:32:11,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:32:11,131 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:32:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:32:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:32:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:32:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:33:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:33:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:33:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:33:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:34:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:34:35,075 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:34:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:34:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:35:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:35:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:35:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:35:38,143 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-36c7fd73-b420-4ce3-89b0-92694e5182fa is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:35:38,143 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:35:38,143 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:35:38,144 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:35:41,152 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:35:41,152 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-094e19ed-aeaf-41a8-9240-64af57796231', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:35:41,153 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:35:41,153 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:35:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:36:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:36:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:36:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:36:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:37:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:37:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:37:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:37:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:38:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:38:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:38:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:38:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:39:08,166 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-094e19ed-aeaf-41a8-9240-64af57796231 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:39:08,166 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:39:08,166 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:39:08,167 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:39:11,176 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:39:11,176 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-76ac2154-ab76-4f56-badf-ce9127ace2bc', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:39:11,176 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:39:11,176 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:39:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:39:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:39:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:39:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:40:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:40:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:40:35,076 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:40:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:41:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:41:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:41:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:41:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:42:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:42:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:42:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:42:38,188 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,188 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,406 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,425 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-76ac2154-ab76-4f56-badf-ce9127ace2bc is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,425 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,425 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:38,426 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:41,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:42:41,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-234f45ea-6434-4614-887f-5ce2a00e2f21', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:42:41,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:42:41,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:42:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:43:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:43:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:43:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:43:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:44:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:44:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:44:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:44:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:45:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:45:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:45:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:45:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:46:08,446 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-234f45ea-6434-4614-887f-5ce2a00e2f21 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:46:08,446 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:46:08,446 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:46:08,447 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:46:11,456 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:46:11,456 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d7e9c7cf-ffa3-4169-88f9-590a841bfdbb', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:46:11,456 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:46:11,456 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:46:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:46:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:46:35,077 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:46:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:47:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:47:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:47:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:47:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:48:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:48:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:48:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:48:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:49:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:49:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:49:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:49:38,466 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,466 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,744 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,764 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-d7e9c7cf-ffa3-4169-88f9-590a841bfdbb is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,764 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,764 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:38,765 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:41,773 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:49:41,773 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-722ea0d3-e983-4942-9a7a-8ccbf24539d8', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:49:41,773 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:49:41,773 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:49:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:50:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:50:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:50:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:50:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:51:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:51:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:51:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:51:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:52:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:52:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:52:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:52:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:53:08,784 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-722ea0d3-e983-4942-9a7a-8ccbf24539d8 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:53:08,785 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:53:08,785 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:53:08,786 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:53:11,793 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:53:11,793 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-3f2fe308-d95d-46a7-b4dd-40a6beb455f5', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:53:11,793 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:53:11,793 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:53:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:53:35,078 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:53:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:53:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:54:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:54:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:54:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:54:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:55:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:55:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:55:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:55:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:56:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:56:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:56:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:56:38,807 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-3f2fe308-d95d-46a7-b4dd-40a6beb455f5 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:56:38,807 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:56:38,807 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:56:38,808 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:56:41,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 12:56:41,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-40696144-768f-4af6-9088-902a6addf1c9', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:56:41,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:56:41,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 12:56:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:57:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:57:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:57:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:57:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:58:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:58:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:58:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:58:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:59:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 12:59:35,079 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:59:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 12:59:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:00:08,834 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:08,834 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:09,044 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:09,060 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-40696144-768f-4af6-9088-902a6addf1c9 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:09,060 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:09,060 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:09,066 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:12,073 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:00:12,073 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0b561ab7-de7f-4976-8f34-c83a13bb0bcc', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:00:12,074 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:00:12,074 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:00:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:00:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:00:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:00:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:01:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:01:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:01:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:01:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:02:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:02:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:02:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:02:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:03:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:03:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:03:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:03:39,091 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,091 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,198 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,216 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-0b561ab7-de7f-4976-8f34-c83a13bb0bcc is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,216 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,216 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:39,217 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:42,226 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:03:42,226 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-e648b13c-06a3-40c9-84f4-7d6e0270f4bc', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:03:42,226 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:03:42,226 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:03:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:04:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:04:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:04:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:04:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:05:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:05:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:05:35,080 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:05:53,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:06:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:06:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:06:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:06:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:07:09,241 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,241 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-2.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,347 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,422 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-e648b13c-06a3-40c9-84f4-7d6e0270f4bc is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,423 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,423 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:09,424 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:12,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:07:12,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-73cfada1-e0cc-402b-bc36-e95f2a37454b', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:07:12,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:07:12,434 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:07:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:07:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:07:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:07:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:08:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:08:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:08:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:08:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:09:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:09:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:09:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:09:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:10:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:10:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:10:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:10:39,527 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,527 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,528 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,628 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-73cfada1-e0cc-402b-bc36-e95f2a37454b is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,628 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,628 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:39,629 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:42,637 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:10:42,637 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-318bf893-37f1-499d-a1d3-f80da5fbca32', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:10:42,637 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:10:42,637 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:10:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:11:23,854 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:11:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:11:35,081 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:11:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:12:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:12:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:12:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:12:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:13:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:13:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:13:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:13:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:14:09,644 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,644 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,646 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,745 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed since coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is either not started or not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,745 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,747 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,747 INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,848 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.strimzi.svc:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,861 INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-318bf893-37f1-499d-a1d3-f80da5fbca32 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,861 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,861 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:09,862 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:12,870 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1]
2020-09-08 13:14:12,870 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-11aeceb0-56d7-498d-b4e3-39a1cb277a2e', leaderUrl='http://10.128.2.57:8083/', offset=20, connectorIds=[mongodb-connector], taskIds=[mongodb-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:14:12,870 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 20 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:14:12,870 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1]
2020-09-08 13:14:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:14:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:14:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:14:53,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:15:23,855 INFO Checking current members of replica set at rs0/mongodb:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery) [debezium-mongodbconnector-dbserver1-replica-set-monitor]
2020-09-08 13:15:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]
2020-09-08 13:15:35,082 INFO WorkerSourceTask{id=mongodb-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [pool-4-thread-1]