[2020-03-23 10:27:46,307] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Connector tdp-s3-sink-task|2020-03-23|1 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1394)
[2020-03-23 10:27:46,308] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2020-03-23 10:27:46,308] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:27:46,813] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Successfully joined group with generation 166 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:27:46,814] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Joined group at generation 166 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-99171604-d1b5-41cf-b94f-d07dd8bbac92', leaderUrl='http://tdp-QA-kafka-connect-003.eu-west-1.ai.memsource.com:10083/', offset=1046, connectorIds=[qa-mongodb-comp-converter-tgroup|2020-02-13|3], taskIds=[qa-mongodb-comp-converter-task|2020-02-13|3-0, qa-mongodb-comp-converter-tgroup|2020-02-13|3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540)
[2020-03-23 10:27:46,814] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connectors and tasks using config offset 1046 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104)
[2020-03-23 10:27:46,814] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125)
[2020-03-23 10:27:47,273] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:27:48,526] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:27:48,526] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:27:50,003] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:27:50,003] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:27:58,526] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:27:58,526] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:00,005] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:00,005] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:04,813] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955684, ord=2, h=8128906778948321878} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:28:05,313] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955684, ord=6, h=563641302267769534} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:28:05,331] INFO 3 records sent for replica set 'qa_set', last offset: {sec=1584955684, ord=5, h=8312918301489064139} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:28:08,527] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:08,527] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:08,530] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:28:10,005] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:10,006] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:10,008] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Finished commitOffsets successfully in 2 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:28:17,274] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:28:18,530] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:18,530] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:20,008] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:20,008] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:28,530] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:28,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:30,008] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:30,008] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:38,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:38,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:40,009] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:40,009] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:47,273] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:28:48,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:48,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:50,009] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:50,009] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:28:58,531] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:28:58,532] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:00,009] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:00,010] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:08,532] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:08,532] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:08,813] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955748, ord=1, h=2681707225753204319} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:08,831] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955748, ord=2, h=-8317102536491427209} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:09,313] INFO 4 records sent for replica set 'qa_set', last offset: {sec=1584955749, ord=3, h=-8672903750655907343} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:09,331] INFO 6 records sent for replica set 'qa_set', last offset: {sec=1584955749, ord=5, h=-6315919000778382790} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:10,010] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:10,010] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:10,013] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:11,814] INFO 2 records sent for replica set 'qa_set', last offset: {sec=1584955751, ord=8, h=-9055363725788028563} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:17,276] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:29:18,532] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:18,532] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:18,536] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Finished commitOffsets successfully in 4 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:20,013] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:20,013] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:21,313] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955761, ord=3, h=3362540741781813928} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:21,814] INFO 4 records sent for replica set 'qa_set', last offset: {sec=1584955761, ord=23, h=8046032006510168971} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:21,832] INFO 7 records sent for replica set 'qa_set', last offset: {sec=1584955761, ord=25, h=-8557014613302425548} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:28,537] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:28,537] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:28,540] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:30,013] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:30,014] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:30,016] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Finished commitOffsets successfully in 2 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:38,540] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:38,540] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:40,016] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:40,017] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:47,273] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:29:47,313] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955787, ord=2, h=7482219612956470228} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:47,813] INFO 1 records sent for replica set 'qa_set', last offset: {sec=1584955787, ord=6, h=-2739754281111275256} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:47,831] INFO 3 records sent for replica set 'qa_set', last offset: {sec=1584955787, ord=5, h=-3665473646797531099} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:29:48,540] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:48,540] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:48,543] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:50,017] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:50,017] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:29:50,019] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Finished commitOffsets successfully in 2 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:29:58,543] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:29:58,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:00,020] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:00,020] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:08,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:08,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:10,020] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:10,020] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:17,274] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:30:18,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:18,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:20,021] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:20,021] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:28,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:28,544] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:30,021] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:30,021] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:38,545] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:38,545] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:40,021] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:40,022] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:43,061] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Connector tdp-s3-sink-tgroup|2020-03-23|1 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1394)
[2020-03-23 10:30:43,061] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2020-03-23 10:30:43,061] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:30:43,568] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Successfully joined group with generation 167 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:30:43,568] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Joined group at generation 167 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-99171604-d1b5-41cf-b94f-d07dd8bbac92', leaderUrl='http://tdp-QA-kafka-connect-003:10083/', offset=1047, connectorIds=[tdp-s3-sink-tgroup|2020-03-23|1, qa-mongodb-comp-converter-tgroup|2020-02-13|3], taskIds=[qa-mongodb-comp-converter-task|2020-02-13|3-0, qa-mongodb-comp-converter-tgroup|2020-02-13|3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540)
[2020-03-23 10:30:43,568] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connectors and tasks using config offset 1047 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104)
[2020-03-23 10:30:43,589] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connector tdp-s3-sink-tgroup|2020-03-23|1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179)
[2020-03-23 10:30:43,598] INFO ConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-tgroup|2020-03-23|1
	tasks.max = 1
	transforms = [ExtractDocument]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-03-23 10:30:43,605] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-tgroup|2020-03-23|1
	tasks.max = 1
	transforms = [ExtractDocument]
	transforms.ExtractDocument.type = class com.memsource.kafka.connect.transforms.ExtractDocument$Value
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:30:43,605] INFO Creating connector tdp-s3-sink-tgroup|2020-03-23|1 of type io.confluent.connect.s3.S3SinkConnector (org.apache.kafka.connect.runtime.Worker:251)
[2020-03-23 10:30:43,612] INFO Instantiated connector tdp-s3-sink-tgroup|2020-03-23|1 with version 5.4.0 of type class io.confluent.connect.s3.S3SinkConnector (org.apache.kafka.connect.runtime.Worker:254)
[2020-03-23 10:30:43,618] INFO S3SinkConnectorConfig values:
	avro.codec = null
	behavior.on.null.values = fail
	connect.meta.data = true
	enhanced.avro.schema.support = false
	filename.offset.zero.pad.width = 10
	flush.size = 150000
	format.bytearray.extension = .bin
	format.bytearray.separator = null
	format.class = class com.memsource.kafka.connect.s3.format.plaintext.PlaintextFormat
	parquet.codec = snappy
	retry.backoff.ms = 5000
	rotate.interval.ms = 3600000
	rotate.schedule.interval.ms = -1
	s3.acl.canned = null
	s3.bucket.name = workspace.ai.eu-west-1.s3.memsource.com
	s3.compression.type = none
	s3.credentials.provider.class = class com.amazonaws.auth.DefaultAWSCredentialsProviderChain
	s3.http.send.expect.continue = true
	s3.part.retries = 3
	s3.part.size = 26214400
	s3.proxy.password = [hidden]
	s3.proxy.url =
	s3.proxy.user = null
	s3.region = eu-west-1
	s3.retry.backoff.ms = 200
	s3.sse.customer.key = [hidden]
	s3.sse.kms.key.id =
	s3.ssea.name =
	s3.wan.mode = false
	schema.cache.size = 1000
	schema.compatibility = NONE
	shutdown.timeout.ms = 3000
 (io.confluent.connect.s3.S3SinkConnectorConfig:347)
[2020-03-23 10:30:43,620] INFO StorageCommonConfig values:
	directory.delim = /
	file.delim = +
	storage.class = class io.confluent.connect.s3.storage.S3Storage
	store.url = null
	topics.dir = 2020-03-01/data/env/qa
 (io.confluent.connect.storage.common.StorageCommonConfig:347)
[2020-03-23 10:30:43,621] INFO PartitionerConfig values:
	locale =
	partition.duration.ms = -1
	partition.field.name = []
	partitioner.class = class io.confluent.connect.storage.partitioner.DefaultPartitioner
	path.format =
	timestamp.extractor = Wallclock
	timestamp.field = timestamp
	timezone =
 (io.confluent.connect.storage.partitioner.PartitionerConfig:347)
[2020-03-23 10:30:43,627] INFO Starting S3 connector tdp-s3-sink-tgroup|2020-03-23|1 (io.confluent.connect.s3.S3SinkConnector:60)
[2020-03-23 10:30:43,627] INFO Finished creating connector tdp-s3-sink-tgroup|2020-03-23|1 (org.apache.kafka.connect.runtime.Worker:273)
[2020-03-23 10:30:43,628] INFO SinkConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name =
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-tgroup|2020-03-23|1
	tasks.max = 1
	topics = [qa-debezium-comp.converter.tgroup]
	topics.regex =
	transforms = [ExtractDocument]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-03-23 10:30:43,630] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name =
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-tgroup|2020-03-23|1
	tasks.max = 1
	topics = [qa-debezium-comp.converter.tgroup]
	topics.regex =
	transforms = [ExtractDocument]
	transforms.ExtractDocument.type = class com.memsource.kafka.connect.transforms.ExtractDocument$Value
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:30:43,637] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125)
[2020-03-23 10:30:47,273] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:30:48,545] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:48,545] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:50,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:50,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:30:58,545] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:30:58,546] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:00,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:00,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:02,813] INFO 3 records sent for replica set 'qa_set', last offset: {sec=1584955862, ord=2, h=3092775484218563128} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:07,313] INFO 2 records sent for replica set 'qa_set', last offset: {sec=1584955866, ord=3, h=-3166076276409131425} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:07,331] INFO 24 records sent for replica set 'qa_set', last offset: {sec=1584955866, ord=15, h=-3955653347554443015} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:07,813] INFO 4 records sent for replica set 'qa_set', last offset: {sec=1584955867, ord=23, h=6316736403688306390} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:07,831] INFO 42 records sent for replica set 'qa_set', last offset: {sec=1584955867, ord=22, h=-7128448936331796770} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:08,314] INFO 2 records sent for replica set 'qa_set', last offset: {sec=1584955867, ord=24, h=-6786929512366663400} (io.debezium.connector.mongodb.MongoDbConnectorTask:219)
[2020-03-23 10:31:08,546] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:08,546] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:08,548] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Finished commitOffsets successfully in 2 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:31:10,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:10,023] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:10,026] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515)
[2020-03-23 10:31:13,575] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:984)
[2020-03-23 10:31:13,575] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2020-03-23 10:31:13,575] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:31:13,584] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Successfully joined group with generation 168 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:31:13,585] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Joined group at generation 168 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-99171604-d1b5-41cf-b94f-d07dd8bbac92', leaderUrl='http://tdp-QA-kafka-connect-003:10083/', offset=1047, connectorIds=[tdp-s3-sink-tgroup|2020-03-23|1, qa-mongodb-comp-converter-tgroup|2020-02-13|3], taskIds=[qa-mongodb-comp-converter-task|2020-02-13|3-0, qa-mongodb-comp-converter-tgroup|2020-02-13|3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=300000} with rebalance delay: 300000 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540)
[2020-03-23 10:31:13,585] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connectors and tasks using config offset 1047 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104)
[2020-03-23 10:31:13,586] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125)
[2020-03-23 10:31:17,273] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:31:18,548] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:18,548] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:20,026] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:20,026] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:22,162] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:66)
[2020-03-23 10:31:22,162] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:321)
[2020-03-23 10:31:22,301] INFO Stopped http_tdp-QA-kafka-connect-00210083@6a9b9909{HTTP/1.1,[http/1.1]}{tdp-QA-kafka-connect-002:10083} (org.eclipse.jetty.server.AbstractConnector:343)
[2020-03-23 10:31:22,301] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:158)
[2020-03-23 10:31:22,305] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:338)
[2020-03-23 10:31:22,305] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:609)
[2020-03-23 10:31:22,306] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:583)
[2020-03-23 10:31:22,321] INFO Stopping connector tdp-s3-sink-tgroup|2020-03-23|1 (org.apache.kafka.connect.runtime.Worker:358)
[2020-03-23 10:31:22,324] INFO Shutting down S3 connector tdp-s3-sink-tgroup|2020-03-23|1 (io.confluent.connect.s3.S3SinkConnector:80)
[2020-03-23 10:31:22,324] INFO Stopping connector qa-mongodb-comp-converter-tgroup|2020-02-13|3 (org.apache.kafka.connect.runtime.Worker:358)
[2020-03-23 10:31:22,325] INFO Stopping MongoDB connector (io.debezium.connector.mongodb.MongoDbConnector:177)
[2020-03-23 10:31:22,326] INFO Closing all connections to mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ConnectionContext:86)
[2020-03-23 10:31:22,326] INFO Closed connection [connectionId{localValue:17, serverValue:358838}] to mongodb-001.eu-west-1.qa.memsource.com:27017 because the pool has been closed. (org.mongodb.driver.connection:71)
[2020-03-23 10:31:22,342] INFO Stopped connector tdp-s3-sink-tgroup|2020-03-23|1 (org.apache.kafka.connect.runtime.Worker:374)
[2020-03-23 10:31:22,342] INFO Stopping task qa-mongodb-comp-converter-tgroup|2020-02-13|3-0 (org.apache.kafka.connect.runtime.Worker:704)
[2020-03-23 10:31:22,342] INFO Stopping MongoDB task (io.debezium.connector.mongodb.MongoDbConnectorTask:166)
[2020-03-23 10:31:22,342] INFO Stopped MongoDB replication task by stopping 1 replicator threads (io.debezium.connector.mongodb.MongoDbConnectorTask:174)
[2020-03-23 10:31:22,343] INFO Stopping task qa-mongodb-comp-converter-task|2020-02-13|3-0 (org.apache.kafka.connect.runtime.Worker:704)
[2020-03-23 10:31:22,343] INFO Stopping MongoDB task (io.debezium.connector.mongodb.MongoDbConnectorTask:166)
[2020-03-23 10:31:22,343] INFO Stopped MongoDB replication task by stopping 1 replicator threads (io.debezium.connector.mongodb.MongoDbConnectorTask:174)
[2020-03-23 10:31:22,344] INFO Stopped MongoDB connector (io.debezium.connector.mongodb.MongoDbConnector:187)
[2020-03-23 10:31:22,345] INFO Stopped connector qa-mongodb-comp-converter-tgroup|2020-02-13|3 (org.apache.kafka.connect.runtime.Worker:374)
[2020-03-23 10:31:22,460] INFO Closing all connections to qa_set/mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ConnectionContext:86)
[2020-03-23 10:31:22,460] INFO Closed connection [connectionId{localValue:27, serverValue:358852}] to mongodb-001.eu-west-1.qa.memsource.com:27017 because the pool has been closed. (org.mongodb.driver.connection:71)
[2020-03-23 10:31:22,461] INFO Closing all connections to qa_set/mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa.memsource.com:27017,mongodb-003.eu-west-1.qa.memsource.com:27017 (io.debezium.connector.mongodb.ConnectionContext:86)
[2020-03-23 10:31:22,461] INFO Closed connection [connectionId{localValue:25, serverValue:358850}] to mongodb-001.eu-west-1.qa.memsource.com:27017 because the pool has been closed. (org.mongodb.driver.connection:71)
[2020-03-23 10:31:24,331] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:24,331] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-tgroup|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:24,331] INFO [Producer clientId=connector-producer-qa-mongodb-comp-converter-tgroup|2020-02-13|3-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2020-03-23 10:31:24,813] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416)
[2020-03-23 10:31:24,813] INFO WorkerSourceTask{id=qa-mongodb-comp-converter-task|2020-02-13|3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)
[2020-03-23 10:31:24,813] INFO [Producer clientId=connector-producer-qa-mongodb-comp-converter-task|2020-02-13|3-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2020-03-23 10:31:24,817] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Member connect-1-129b2616-3cd9-4a61-916b-866d4b2f1d04 sending LeaveGroup request to coordinator tdp-QA-CP-kafka-broker-001:9092 (id: 2147482644 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:916)
[2020-03-23 10:31:24,818] WARN [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:897)
[2020-03-23 10:31:24,820] INFO Stopping KafkaBasedLog for topic connect-status-qa (org.apache.kafka.connect.util.KafkaBasedLog:165)
[2020-03-23 10:31:24,828] INFO [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2020-03-23 10:31:24,836] INFO Stopped KafkaBasedLog for topic connect-status-qa (org.apache.kafka.connect.util.KafkaBasedLog:191)
[2020-03-23 10:31:24,837] INFO Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:272)
[2020-03-23 10:31:24,837] INFO Stopping KafkaBasedLog for topic connect-configs-qa (org.apache.kafka.connect.util.KafkaBasedLog:165)
[2020-03-23 10:31:24,838] INFO [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2020-03-23 10:31:24,855] INFO Stopped KafkaBasedLog for topic connect-configs-qa (org.apache.kafka.connect.util.KafkaBasedLog:191)
[2020-03-23 10:31:24,855] INFO Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:274)
[2020-03-23 10:31:24,856] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:198)
[2020-03-23 10:31:24,857] INFO Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:115)
[2020-03-23 10:31:24,857] INFO Stopping KafkaBasedLog for topic connect-offsets-qa (org.apache.kafka.connect.util.KafkaBasedLog:165)
[2020-03-23 10:31:24,861] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2020-03-23 10:31:24,869] INFO Stopped KafkaBasedLog for topic connect-offsets-qa (org.apache.kafka.connect.util.KafkaBasedLog:191)
[2020-03-23 10:31:24,869] INFO Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:117)
[2020-03-23 10:31:24,878] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:219)
[2020-03-23 10:31:24,879] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:287)
[2020-03-23 10:31:24,897] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:629)
[2020-03-23 10:31:24,897] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:71)
[2020-03-23 10:31:49,038] INFO WorkerInfo values:
	jvm.args = -Xms256M, -Xmx1G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/var/log/kafka, -Dlog4j.configuration=file:/etc/kafka/connect-log4j.properties
	jvm.spec = Private Build, OpenJDK 64-Bit Server VM, 11.0.5, 11.0.5+10-post-Ubuntu-0ubuntu1.118.04
	jvm.classpath = /usr/share/java/kafka/scala-reflect-2.11.12.jar:/usr/share/java/kafka/audience-annotations-0.5.0.jar:/usr/share/java/kafka/scala-java8-compat_2.11-0.9.0.jar:/usr/share/java/kafka/plexus-utils-3.2.0.jar:/usr/share/java/kafka/jersey-server-2.28.jar:/usr/share/java/kafka/guava-20.0.jar:/usr/share/java/kafka/connect-mirror-client-5.4.0-ccs.jar:/usr/share/java/kafka/commons-cli-1.4.jar:/usr/share/java/kafka/support-metrics-client-5.4.0-ccs.jar:/usr/share/java/kafka/zstd-jni-1.4.3-1.jar:/usr/share/java/kafka/jersey-container-servlet-2.28.jar:/usr/share/java/kafka/metrics-core-2.2.0.jar:/usr/share/java/kafka/connect-runtime-5.4.0-ccs.jar:/usr/share/java/kafka/zookeeper-jute-3.5.6.jar:/usr/share/java/kafka/jackson-core-2.9.10.jar:/usr/share/java/kafka/connect-json-5.4.0-ccs.jar:/usr/share/java/kafka/scala-library-2.11.12.jar:/usr/share/java/kafka/kafka-streams-test-utils-5.4.0-ccs.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs-sources.jar:/usr/share/java/kafka/jakarta.annotation-api-1.3.4.jar:/usr/share/java/kafka/kafka-clients-5.4.0-ccs.jar:/usr/share/java/kafka/jackson-jaxrs-json-provider-2.9.10.jar:/usr/share/java/kafka/lz4-java-1.6.0.jar:/usr/share/java/kafka/netty-transport-native-epoll-4.1.42.Final.jar:/usr/share/java/kafka/netty-transport-4.1.42.Final.jar:/usr/share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/usr/share/java/kafka/connect-api-5.4.0-ccs.jar:/usr/share/java/kafka/slf4j-api-1.7.28.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs-test.jar:/usr/share/java/kafka/jetty-client-9.4.20.v20190813.jar:/usr/share/java/kafka/jetty-servlets-9.4.20.v20190813.jar:/usr/share/java/kafka/jackson-annotations-2.9.10.jar:/usr/share/java/kafka/commons-compress-1.19.jar:/usr/share/java/kafka/support-metrics-common-5.4.0-ccs.jar:/usr/share/java/kafka/connect-file-5.4.0-ccs.jar:/usr/share/java/kafka/commons-logging-1.2.jar:/usr/share/java/kafka/jackson-jaxrs-base-2.9.10.jar:/usr/share/java/kafka/jackson-module-paranamer-2.9.10.jar:/usr/share/java/kafka/netty-codec-4.1.42.Final.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs-javadoc.jar:/usr/share/java/kafka/validation-api-2.0.1.Final.jar:/usr/share/java/kafka/jackson-datatype-jdk8-2.9.10.jar:/usr/share/java/kafka/hk2-utils-2.5.0.jar:/usr/share/java/kafka/jetty-servlet-9.4.20.v20190813.jar:/usr/share/java/kafka/maven-artifact-3.6.1.jar:/usr/share/java/kafka/netty-handler-4.1.42.Final.jar:/usr/share/java/kafka/jersey-hk2-2.28.jar:/usr/share/java/kafka/kafka.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs-test-sources.jar:/usr/share/java/kafka/jetty-security-9.4.20.v20190813.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs-scaladoc.jar:/usr/share/java/kafka/httpclient-4.5.9.jar:/usr/share/java/kafka/avro-1.9.1.jar:/usr/share/java/kafka/kafka-streams-scala_2.11-5.4.0-ccs.jar:/usr/share/java/kafka/jaxb-api-2.3.0.jar:/usr/share/java/kafka/activation-1.1.1.jar:/usr/share/java/kafka/httpmime-4.5.9.jar:/usr/share/java/kafka/javassist-3.22.0-CR2.jar:/usr/share/java/kafka/jackson-databind-2.9.10.1.jar:/usr/share/java/kafka/jersey-common-2.28.jar:/usr/share/java/kafka/kafka-log4j-appender-5.4.0-ccs.jar:/usr/share/java/kafka/jersey-container-servlet-core-2.28.jar:/usr/share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/share/java/kafka/snappy-java-1.1.7.3.jar:/usr/share/java/kafka/scala-logging_2.11-3.9.2.jar:/usr/share/java/kafka/jersey-client-2.28.jar:/usr/share/java/kafka/jackson-module-jaxb-annotations-2.9.10.jar:/usr/share/java/kafka/kafka-streams-examples-5.4.0-ccs.jar:/usr/share/java/kafka/kafka_2.11-5.4.0-ccs.jar:/usr/share/java/kafka/scala-collection-compat_2.11-2.1.2.jar:/usr/share/java/kafka/netty-transport-native-unix-common-4.1.42.Final.jar:/usr/share/java/kafka/netty-common-4.1.42.Final.jar:/usr/share/java/kafka/commons-lang3-3.8.1.jar:/usr/share/java/kafka/osgi-resource-locator-1.0.1.jar:/usr/share/java/kafka/rocksdbjni-5.18.3.jar:/usr/share/java/kafka/commons-codec-1.11.jar:/usr/share/java/kafka/netty-resolver-4.1.42.Final.jar:/usr/share/java/kafka/jetty-io-9.4.20.v20190813.jar:/usr/share/java/kafka/jersey-media-jaxb-2.28.jar:/usr/share/java/kafka/connect-basic-auth-extension-5.4.0-ccs.jar:/usr/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/share/java/kafka/paranamer-2.8.jar:/usr/share/java/kafka/jackson-module-scala_2.11-2.9.10.jar:/usr/share/java/kafka/jopt-simple-5.0.4.jar:/usr/share/java/kafka/hk2-locator-2.5.0.jar:/usr/share/java/kafka/jetty-util-9.4.20.v20190813.jar:/usr/share/java/kafka/log4j-1.2.17.jar:/usr/share/java/kafka/reflections-0.9.11.jar:/usr/share/java/kafka/aopalliance-repackaged-2.5.0.jar:/usr/share/java/kafka/connect-transforms-5.4.0-ccs.jar:/usr/share/java/kafka/netty-buffer-4.1.42.Final.jar:/usr/share/java/kafka/argparse4j-0.7.0.jar:/usr/share/java/kafka/jetty-http-9.4.20.v20190813.jar:/usr/share/java/kafka/zookeeper-3.5.6.jar:/usr/share/java/kafka/jetty-server-9.4.20.v20190813.jar:/usr/share/java/kafka/hk2-api-2.5.0.jar:/usr/share/java/kafka/jackson-dataformat-csv-2.9.10.jar:/usr/share/java/kafka/kafka-streams-5.4.0-ccs.jar:/usr/share/java/kafka/kafka-tools-5.4.0-ccs.jar:/usr/share/java/kafka/connect-mirror-5.4.0-ccs.jar:/usr/share/java/kafka/httpcore-4.4.11.jar:/usr/share/java/kafka/jakarta.inject-2.5.0.jar:/usr/share/java/kafka/jetty-continuation-9.4.20.v20190813.jar:/usr/share/java/kafka/slf4j-log4j12-1.7.28.jar:/usr/share/java/confluent-common/zookeeper-3.4.14.jar:/usr/share/java/confluent-common/audience-annotations-0.5.0.jar:/usr/share/java/confluent-common/jsr305-3.0.2.jar:/usr/share/java/confluent-common/build-tools-5.3.2.jar:/usr/share/java/confluent-common/common-metrics-5.3.2.jar:/usr/share/java/confluent-common/common-config-5.3.2.jar:/usr/share/java/confluent-common/slf4j-api-1.7.26.jar:/usr/share/java/confluent-common/spotbugs-annotations-3.1.8.jar:/usr/share/java/confluent-common/jline-0.9.94.jar:/usr/share/java/confluent-common/netty-3.10.6.Final.jar:/usr/share/java/confluent-common/common-utils-5.3.2.jar:/usr/share/java/confluent-common/zkclient-0.10.jar:/usr/share/java/kafka-serde-tools/guava-20.0.jar:/usr/share/java/kafka-serde-tools/kafka-json-serializer-5.4.0.jar:/usr/share/java/kafka-serde-tools/swagger-models-1.5.3.jar:/usr/share/java/kafka-serde-tools/swagger-annotations-1.5.22.jar:/usr/share/java/kafka-serde-tools/jackson-core-2.9.10.jar:/usr/share/java/kafka-serde-tools/jackson-annotations-2.9.10.jar:/usr/share/java/kafka-serde-tools/commons-compress-1.19.jar:/usr/share/java/kafka-serde-tools/jackson-datatype-joda-2.9.10.jar:/usr/share/java/kafka-serde-tools/snakeyaml-1.23.jar:/usr/share/java/kafka-serde-tools/kafka-avro-serializer-5.4.0.jar:/usr/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.4.0.jar:/usr/share/java/kafka-serde-tools/avro-1.9.1.jar:/usr/share/java/kafka-serde-tools/kafka-schema-registry-client-5.4.0.jar:/usr/share/java/kafka-serde-tools/jackson-databind-2.9.10.1.jar:/usr/share/java/kafka-serde-tools/swagger-core-1.5.3.jar:/usr/share/java/kafka-serde-tools/jackson-dataformat-yaml-2.9.10.jar:/usr/share/java/kafka-serde-tools/joda-time-2.7.jar:/usr/share/java/kafka-serde-tools/commons-lang3-3.8.1.jar:/usr/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.4.0.jar:/usr/bin/../share/java/kafka/scala-reflect-2.11.12.jar:/usr/bin/../share/java/kafka/audience-annotations-0.5.0.jar:/usr/bin/../share/java/kafka/scala-java8-compat_2.11-0.9.0.jar:/usr/bin/../share/java/kafka/plexus-utils-3.2.0.jar:/usr/bin/../share/java/kafka/jersey-server-2.28.jar:/usr/bin/../share/java/kafka/guava-20.0.jar:/usr/bin/../share/java/kafka/connect-mirror-client-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/commons-cli-1.4.jar:/usr/bin/../share/java/kafka/support-metrics-client-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/zstd-jni-1.4.3-1.jar:/usr/bin/../share/java/kafka/jersey-container-servlet-2.28.jar:/usr/bin/../share/java/kafka/metrics-core-2.2.0.jar:/usr/bin/../share/java/kafka/connect-runtime-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/zookeeper-jute-3.5.6.jar:/usr/bin/../share/java/kafka/jackson-core-2.9.10.jar:/usr/bin/../share/java/kafka/connect-json-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/scala-library-2.11.12.jar:/usr/bin/../share/java/kafka/kafka-streams-test-utils-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs-sources.jar:/usr/bin/../share/java/kafka/jakarta.annotation-api-1.3.4.jar:/usr/bin/../share/java/kafka/kafka-clients-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.10.jar:/usr/bin/../share/java/kafka/lz4-java-1.6.0.jar:/usr/bin/../share/java/kafka/netty-transport-native-epoll-4.1.42.Final.jar:/usr/bin/../share/java/kafka/netty-transport-4.1.42.Final.jar:/usr/bin/../share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/usr/bin/../share/java/kafka/connect-api-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/slf4j-api-1.7.28.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs-test.jar:/usr/bin/../share/java/kafka/jetty-client-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/jetty-servlets-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/jackson-annotations-2.9.10.jar:/usr/bin/../share/java/kafka/commons-compress-1.19.jar:/usr/bin/../share/java/kafka/support-metrics-common-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/connect-file-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/commons-logging-1.2.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-base-2.9.10.jar:/usr/bin/../share/java/kafka/jackson-module-paranamer-2.9.10.jar:/usr/bin/../share/java/kafka/netty-codec-4.1.42.Final.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs-javadoc.jar:/usr/bin/../share/java/kafka/validation-api-2.0.1.Final.jar:/usr/bin/../share/java/kafka/jackson-datatype-jdk8-2.9.10.jar:/usr/bin/../share/java/kafka/hk2-utils-2.5.0.jar:/usr/bin/../share/java/kafka/jetty-servlet-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/maven-artifact-3.6.1.jar:/usr/bin/../share/java/kafka/netty-handler-4.1.42.Final.jar:/usr/bin/../share/java/kafka/jersey-hk2-2.28.jar:/usr/bin/../share/java/kafka/kafka.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs-test-sources.jar:/usr/bin/../share/java/kafka/jetty-security-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs-scaladoc.jar:/usr/bin/../share/java/kafka/httpclient-4.5.9.jar:/usr/bin/../share/java/kafka/avro-1.9.1.jar:/usr/bin/../share/java/kafka/kafka-streams-scala_2.11-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/usr/bin/../share/java/kafka/activation-1.1.1.jar:/usr/bin/../share/java/kafka/httpmime-4.5.9.jar:/usr/bin/../share/java/kafka/javassist-3.22.0-CR2.jar:/usr/bin/../share/java/kafka/jackson-databind-2.9.10.1.jar:/usr/bin/../share/java/kafka/jersey-common-2.28.jar:/usr/bin/../share/java/kafka/kafka-log4j-appender-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/jersey-container-servlet-core-2.28.jar:/usr/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/kafka/snappy-java-1.1.7.3.jar:/usr/bin/../share/java/kafka/scala-logging_2.11-3.9.2.jar:/usr/bin/../share/java/kafka/jersey-client-2.28.jar:/usr/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.10.jar:/usr/bin/../share/java/kafka/kafka-streams-examples-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/kafka_2.11-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/scala-collection-compat_2.11-2.1.2.jar:/usr/bin/../share/java/kafka/netty-transport-native-unix-common-4.1.42.Final.jar:/usr/bin/../share/java/kafka/netty-common-4.1.42.Final.jar:/usr/bin/../share/java/kafka/commons-lang3-3.8.1.jar:/usr/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/usr/bin/../share/java/kafka/rocksdbjni-5.18.3.jar:/usr/bin/../share/java/kafka/commons-codec-1.11.jar:/usr/bin/../share/java/kafka/netty-resolver-4.1.42.Final.jar:/usr/bin/../share/java/kafka/jetty-io-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/jersey-media-jaxb-2.28.jar:/usr/bin/../share/java/kafka/connect-basic-auth-extension-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/kafka/paranamer-2.8.jar:/usr/bin/../share/java/kafka/jackson-module-scala_2.11-2.9.10.jar:/usr/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/usr/bin/../share/java/kafka/hk2-locator-2.5.0.jar:/usr/bin/../share/java/kafka/jetty-util-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/log4j-1.2.17.jar:/usr/bin/../share/java/kafka/reflections-0.9.11.jar:/usr/bin/../share/java/kafka/aopalliance-repackaged-2.5.0.jar:/usr/bin/../share/java/kafka/connect-transforms-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/netty-buffer-4.1.42.Final.jar:/usr/bin/../share/java/kafka/argparse4j-0.7.0.jar:/usr/bin/../share/java/kafka/jetty-http-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/zookeeper-3.5.6.jar:/usr/bin/../share/java/kafka/jetty-server-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/hk2-api-2.5.0.jar:/usr/bin/../share/java/kafka/jackson-dataformat-csv-2.9.10.jar:/usr/bin/../share/java/kafka/kafka-streams-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/kafka-tools-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/connect-mirror-5.4.0-ccs.jar:/usr/bin/../share/java/kafka/httpcore-4.4.11.jar:/usr/bin/../share/java/kafka/jakarta.inject-2.5.0.jar:/usr/bin/../share/java/kafka/jetty-continuation-9.4.20.v20190813.jar:/usr/bin/../share/java/kafka/slf4j-log4j12-1.7.28.jar:/usr/bin/../support-metrics-client/build/dependant-libs-2.12.10/*:/usr/bin/../support-metrics-client/build/libs/*:/usr/share/java/support-metrics-client/*
	os.spec = Linux, amd64, 4.15.0-1052-aws
	os.vcpus = 2
 (org.apache.kafka.connect.runtime.WorkerInfo:71)
[2020-03-23 10:31:49,059] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90)
[2020-03-23 10:31:49,093] INFO Loading plugin from: /opt/kafka-connect/plugins/memsource-connect-transforms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:49,349] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka-connect/plugins/memsource-connect-transforms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:49,351] INFO Added plugin 'com.memsource.kafka.connect.transforms.ExtractDocument$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,352] INFO Added plugin 'com.memsource.kafka.connect.transforms.ExtractDocument$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,352] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,358] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,358] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,366] INFO Loading plugin from: /opt/kafka-connect/plugins/debezium-connector-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:49,794] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka-connect/plugins/debezium-connector-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:49,794] INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,794] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,794] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,796] INFO Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,796] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:49,811] INFO Loading plugin from: /usr/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:50,144] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:50,144] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:50,148] INFO Loading plugin from: /usr/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:53,143] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:53,143] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:53,143] INFO Loading plugin from: /usr/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:53,262] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:53,262] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:53,262] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:53,277] INFO Loading plugin from: /usr/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:55,504] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:55,504] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,504] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,507] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,507] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,507] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,508] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,508] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,508] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,508] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,509] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,510] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,511] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,511] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,511] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,512] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,512] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,512] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,512] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,512] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,513] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,514] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,515] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,515] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,515] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,515] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,515] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,516] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:55,516] INFO Loading plugin from: /usr/share/java/libintl.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:55,523] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/libintl.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:55,523] INFO Loading plugin from: /usr/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:56,249] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:56,249] INFO Loading plugin from: /usr/share/java/ksql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:57,908] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ksql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:57,908] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:57,909] INFO Loading plugin from: /usr/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:58,134] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:58,135] INFO Loading plugin from: /usr/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:59,204] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:59,204] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:31:59,205] INFO Loading plugin from: /usr/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:31:59,287] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:31:59,288] INFO Loading plugin from: /usr/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:32:01,955] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:32:01,955] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193)
[2020-03-23 10:32:01,956] INFO Loading plugin from: /usr/share/java/kafka-rest (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241)
[2020-03-23 10:32:03,767] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-rest/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:32:07,106] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@6bc7c054 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264)
[2020-03-23 10:32:07,107] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,107] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,107] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,107] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,108] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,109] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,109] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,109] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,109] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,109] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,110] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,111] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,112] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,112] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,112] INFO Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,112] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,113] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,113] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,113] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,114] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,114] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,114] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411)
[2020-03-23 10:32:07,114] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,114] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,114] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414)
[2020-03-23 10:32:07,203] INFO DistributedConfig values:
	access.control.allow.methods =
	access.control.allow.origin =
	admin.listeners = null
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	client.dns.lookup = default
	client.id =
	config.providers = []
	config.storage.replication.factor = 3
	config.storage.topic = connect-configs-qa
	connect.protocol = sessioned
	connections.max.idle.ms = 540000
	connector.client.config.override.policy = None
	group.id = tdp-QA-connect-cluster
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	heartbeat.interval.ms = 3000
	inter.worker.key.generation.algorithm = HmacSHA256
	inter.worker.key.size = null
	inter.worker.key.ttl.ms = 3600000
	inter.worker.signature.algorithm = HmacSHA256
	inter.worker.verification.algorithms = [HmacSHA256]
	internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
	internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	listeners = null
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	offset.flush.interval.ms = 10000
	offset.flush.timeout.ms = 5000
	offset.storage.partitions = 5
	offset.storage.replication.factor = 3
	offset.storage.topic = connect-offsets-qa
	plugin.path = [/opt/kafka-connect/plugins, /usr/share/java/]
	rebalance.timeout.ms = 60000
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 40000
	rest.advertised.host.name = tdp-QA-kafka-connect-002
	rest.advertised.listener = null
	rest.advertised.port = 10083
	rest.extension.classes = []
	rest.host.name = tdp-QA-kafka-connect-002
	rest.port = 10083
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	scheduled.rebalance.max.delay.ms = 300000
	security.protocol = SSL
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	status.storage.partitions = 3
	status.storage.replication.factor = 3
	status.storage.topic = connect-status-qa
	task.shutdown.graceful.timeout.ms = 5000
	value.converter = class org.apache.kafka.connect.json.JsonConverter
	worker.sync.timeout.ms = 3000
	worker.unsync.backoff.ms = 300000
 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:347)
[2020-03-23 10:32:07,204] INFO Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:343)
[2020-03-23 10:32:07,204] INFO Worker configuration property 'internal.key.converter.schemas.enable' (along with all configuration for 'internal.key.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:343)
[2020-03-23 10:32:07,204] INFO Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:343)
[2020-03-23 10:32:07,204] INFO Worker configuration property 'internal.value.converter.schemas.enable' (along with all configuration for 'internal.value.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:343)
[2020-03-23 10:32:07,207] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
[2020-03-23 10:32:07,209] INFO AdminClientConfig values:
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2020-03-23 10:32:07,673] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,673] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,674] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,675] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:07,676] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:07,676] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:07,676] INFO Kafka startTimeMs: 1584955927675 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:08,400] INFO Kafka cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.connect.util.ConnectUtils:59)
[2020-03-23 10:32:08,431] INFO Logging initialized @21036ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:169)
[2020-03-23 10:32:08,472] INFO Added connector for http://tdp-QA-kafka-connect-002:10083 (org.apache.kafka.connect.runtime.rest.RestServer:131)
[2020-03-23 10:32:08,473] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:203)
[2020-03-23 10:32:08,480] INFO jetty-9.4.20.v20190813; built: 2019-08-13T21:28:18.144Z; git: 84700530e645e812b336747464d6fbbf370c9a20; jvm 11.0.5+10-post-Ubuntu-0ubuntu1.118.04 (org.eclipse.jetty.server.Server:359)
[2020-03-23 10:32:08,511] INFO Started http_tdp-QA-kafka-connect-00210083@84487f4{HTTP/1.1,[http/1.1]}{tdp-QA-kafka-connect-002:10083} (org.eclipse.jetty.server.AbstractConnector:293)
[2020-03-23 10:32:08,511] INFO Started @21116ms (org.eclipse.jetty.server.Server:399)
[2020-03-23 10:32:08,539] INFO Advertised URI: http://tdp-QA-kafka-connect-002:10083/ (org.apache.kafka.connect.runtime.rest.RestServer:365)
[2020-03-23 10:32:08,539] INFO REST server listening at http://tdp-QA-kafka-connect-002:10083/, advertising URL http://tdp-QA-kafka-connect-002:10083/ (org.apache.kafka.connect.runtime.rest.RestServer:218)
[2020-03-23 10:32:08,539] INFO Advertised URI: http://tdp-QA-kafka-connect-002:10083/ (org.apache.kafka.connect.runtime.rest.RestServer:365)
[2020-03-23 10:32:08,539] INFO REST admin endpoints at http://tdp-QA-kafka-connect-002:10083/ (org.apache.kafka.connect.runtime.rest.RestServer:219)
[2020-03-23 10:32:08,540] INFO Advertised URI: http://tdp-QA-kafka-connect-002:10083/ (org.apache.kafka.connect.runtime.rest.RestServer:365)
[2020-03-23 10:32:08,544] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2020-03-23 10:32:08,552] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:08,552] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:08,552] INFO Kafka startTimeMs: 1584955928551 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:08,649] INFO JsonConverterConfig values:
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-03-23 10:32:08,651] INFO JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-03-23 10:32:08,777] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:08,778] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:08,778] INFO Kafka startTimeMs: 1584955928777 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:08,784] INFO Kafka Connect distributed worker initialization took 19725ms (org.apache.kafka.connect.cli.ConnectDistributed:128)
[2020-03-23 10:32:08,785] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
[2020-03-23 10:32:08,785] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:223)
[2020-03-23 10:32:08,785] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:275)
[2020-03-23 10:32:08,787] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184)
[2020-03-23 10:32:08,787] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108)
[2020-03-23 10:32:08,787] INFO Starting KafkaBasedLog with topic connect-offsets-qa (org.apache.kafka.connect.util.KafkaBasedLog:126)
[2020-03-23 10:32:08,790] INFO AdminClientConfig values:
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2020-03-23 10:32:08,856] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:240)
[2020-03-23 10:32:08,918] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,927] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,928] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:08,929] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:08,935] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:08,935] INFO Kafka startTimeMs: 1584955928929 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:08,976] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:333)
[2020-03-23 10:32:08,981] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:338)
[2020-03-23 10:32:08,982] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:140)
[2020-03-23 10:32:09,131] INFO ProducerConfig values:
	acks = all
	batch.size = 16384
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id =
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 1
	max.request.size = 20000000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig:347)
[2020-03-23 10:32:09,369] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,370] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,371] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,372] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,374] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:09,375] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:09,375] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:09,375] INFO Kafka startTimeMs: 1584955929375 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:09,400] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	check.crcs = true
	client.dns.lookup = default
	client.id =
	client.rack =
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = tdp-QA-connect-cluster
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 20000000
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-03-23 10:32:09,441] INFO [Producer clientId=producer-1] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:09,621] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,632] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,633] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,634] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,634] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,634] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,634] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:09,634] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:09,634] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:09,634] INFO Kafka startTimeMs: 1584955929634 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:09,686] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:09,767] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Subscribed to partition(s): connect-offsets-qa-0, connect-offsets-qa-1, connect-offsets-qa-4, connect-offsets-qa-2, connect-offsets-qa-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)
[2020-03-23 10:32:09,771] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-qa-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:09,771] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-qa-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:09,771] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-qa-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:09,771] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-qa-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:09,771] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-qa-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:09,976] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-offsets-qa-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:09,978] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-offsets-qa-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:09,978] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-offsets-qa-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:09,978] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-offsets-qa-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:09,978] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-1, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-offsets-qa-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:10,225] INFO Started o.e.j.s.ServletContextHandler@3a2d3909{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:824)
[2020-03-23 10:32:10,225] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:313)
[2020-03-23 10:32:10,225] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2020-03-23 10:32:10,577] INFO Finished reading KafkaBasedLog for topic connect-offsets-qa (org.apache.kafka.connect.util.KafkaBasedLog:159)
[2020-03-23 10:32:10,577] INFO Started KafkaBasedLog for topic connect-offsets-qa (org.apache.kafka.connect.util.KafkaBasedLog:161)
[2020-03-23 10:32:10,577] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110)
[2020-03-23 10:32:10,583] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191)
[2020-03-23 10:32:10,583] INFO Starting KafkaBasedLog with topic connect-status-qa (org.apache.kafka.connect.util.KafkaBasedLog:126)
[2020-03-23 10:32:10,589] INFO AdminClientConfig values:
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2020-03-23 10:32:10,719] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,719] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,720] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,725] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:10,726] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:10,726] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:10,726] INFO Kafka startTimeMs: 1584955930725 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:10,805] INFO ProducerConfig values:
	acks = all
	batch.size = 16384
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id =
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 1
	max.request.size = 20000000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 0
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig:347)
[2020-03-23 10:32:10,911] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,913] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,914] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,917] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,917] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:10,921] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:10,928] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:10,929] INFO Kafka startTimeMs: 1584955930921 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:10,929] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	check.crcs = true
	client.dns.lookup = default
	client.id =
	client.rack =
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = tdp-QA-connect-cluster
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 20000000
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-03-23 10:32:10,988] INFO [Producer clientId=producer-2] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:11,049] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,049] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,050] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,051] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:11,051] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:11,051] INFO Kafka startTimeMs: 1584955931051 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:11,075] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:11,101] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Subscribed to partition(s): connect-status-qa-0, connect-status-qa-2, connect-status-qa-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)
[2020-03-23 10:32:11,102] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-status-qa-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:11,102] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-status-qa-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:11,102] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-status-qa-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:11,232] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-status-qa-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:11,233] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-status-qa-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:11,236] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-2, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-status-qa-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:11,285] INFO Finished reading KafkaBasedLog for topic connect-status-qa (org.apache.kafka.connect.util.KafkaBasedLog:159)
[2020-03-23 10:32:11,285] INFO Started KafkaBasedLog for topic connect-status-qa (org.apache.kafka.connect.util.KafkaBasedLog:161)
[2020-03-23 10:32:11,285] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:262)
[2020-03-23 10:32:11,285] INFO Starting KafkaBasedLog with topic connect-configs-qa (org.apache.kafka.connect.util.KafkaBasedLog:126)
[2020-03-23 10:32:11,286] INFO AdminClientConfig values:
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2020-03-23 10:32:11,374] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,374] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,375] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-03-23 10:32:11,376] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:11,377] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:11,377] INFO Kafka startTimeMs: 1584955931376 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:11,463] INFO ProducerConfig values:
	acks = all
	batch.size = 16384
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id =
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 1
	max.request.size = 20000000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig:347)
[2020-03-23 10:32:11,649] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,649] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,650] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,651] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,651] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,651] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,651] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2020-03-23 10:32:11,651] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:11,651] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:11,651] INFO Kafka startTimeMs: 1584955931651 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:11,652] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	check.crcs = true
	client.dns.lookup = default
	client.id =
	client.rack =
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = tdp-QA-connect-cluster
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 20000000
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-03-23 10:32:11,720] INFO [Producer clientId=producer-3] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:11,774] WARN The configuration 'consumer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,775] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'producer.ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,776] WARN The configuration 'consumer.max.partition.fetch.bytes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2020-03-23 10:32:11,777] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:11,777] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:11,777] INFO Kafka startTimeMs: 1584955931776 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:11,807] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-3, groupId=tdp-QA-connect-cluster] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:11,839] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-3, groupId=tdp-QA-connect-cluster] Subscribed to partition(s): connect-configs-qa-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)
[2020-03-23 10:32:11,840] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-3, groupId=tdp-QA-connect-cluster] Seeking to EARLIEST offset of partition connect-configs-qa-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568)
[2020-03-23 10:32:11,933] INFO [Consumer clientId=consumer-tdp-QA-connect-cluster-3, groupId=tdp-QA-connect-cluster] Resetting offset for partition connect-configs-qa-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:11,945] INFO Successfully processed removal of connector 'test-qa-mongodb-converter-task|2019-07-23|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,947] INFO Successfully processed removal of connector 'qa-mongodb-converter-task|2019-07-25|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,947] INFO Successfully processed removal of connector 'qa-mongodb-converter-tgroup|2019-07-25|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,949] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-08|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,952] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-09|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,957] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-09|2' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,958] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-09|3' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,958] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-09|4' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,958] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-10|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,959] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-10|2' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,959] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-10|3' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,959] INFO Successfully processed removal of connector 'tdp-s3-sink-tgroup|2020-01-10|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,960] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-14|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,960] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-14|2' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,960] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-14|3' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,966] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-01-14|4' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,966] INFO Successfully processed removal of connector 'tdp-s3-sink-tgroup|2020-01-14|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,966] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-task|2020-01-07|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,966] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-tgroup|2020-01-07|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,966] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-tgroup|2020-02-13|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,967] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-task|2020-02-13|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,967] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-tgroup|2020-02-13|2' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,967] INFO Successfully processed removal of connector 'qa-mongodb-comp-converter-task|2020-02-13|2' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,979] INFO Successfully processed removal of connector 'tdp-s3-sink-task|2020-02-14|1' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:549)
[2020-03-23 10:32:11,985] INFO Finished reading KafkaBasedLog for topic connect-configs-qa (org.apache.kafka.connect.util.KafkaBasedLog:159)
[2020-03-23 10:32:11,985] INFO Started KafkaBasedLog for topic connect-configs-qa (org.apache.kafka.connect.util.KafkaBasedLog:161)
[2020-03-23 10:32:11,985] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:267)
[2020-03-23 10:32:11,985] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:279)
[2020-03-23 10:32:12,023] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:12,024] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Discovered group coordinator tdp-QA-CP-kafka-broker-001:9092 (id: 2147482644 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:756)
[2020-03-23 10:32:12,027] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2020-03-23 10:32:12,027] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:32:12,055] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:32:12,301] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1438)
[2020-03-23 10:32:12,817] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Successfully joined group with generation 171 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:32:12,819] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Joined group at generation 171 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-87f95b3e-6a0d-4d49-993d-7521bc1d73f2', leaderUrl='http://tdp-QA-kafka-connect-003:10083/', offset=1052, connectorIds=[], taskIds=[tdp-s3-sink-task|2020-03-23|1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540)
[2020-03-23 10:32:12,820] WARN [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1013)
[2020-03-23 10:32:12,820] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Current config state offset -1 is behind group assignment 1052, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1074)
[2020-03-23 10:32:13,304] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 1052 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1078)
[2020-03-23 10:32:13,305] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connectors and tasks using config offset 1052 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104)
[2020-03-23 10:32:13,306] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting task tdp-s3-sink-task|2020-03-23|1-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1139)
[2020-03-23 10:32:13,312] INFO Creating task tdp-s3-sink-task|2020-03-23|1-0 (org.apache.kafka.connect.runtime.Worker:419)
[2020-03-23 10:32:13,322] INFO ConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-task|2020-03-23|1
	tasks.max = 1
	transforms = [ExtractDocument]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-03-23 10:32:13,326] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-task|2020-03-23|1
	tasks.max = 1
	transforms = [ExtractDocument]
	transforms.ExtractDocument.type = class com.memsource.kafka.connect.transforms.ExtractDocument$Value
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:32:13,330] INFO TaskConfig values:
	task.class = class io.confluent.connect.s3.S3SinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-03-23 10:32:13,333] INFO Instantiated task tdp-s3-sink-task|2020-03-23|1-0 with version 5.4.0 of type io.confluent.connect.s3.S3SinkTask (org.apache.kafka.connect.runtime.Worker:434)
[2020-03-23 10:32:13,333] INFO JsonConverterConfig values:
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-03-23 10:32:13,334] INFO JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-03-23 10:32:13,334] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task tdp-s3-sink-task|2020-03-23|1-0 using the connector config (org.apache.kafka.connect.runtime.Worker:449)
[2020-03-23 10:32:13,334] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task tdp-s3-sink-task|2020-03-23|1-0 using the connector config (org.apache.kafka.connect.runtime.Worker:455)
[2020-03-23 10:32:13,335] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task tdp-s3-sink-task|2020-03-23|1-0 using the worker config (org.apache.kafka.connect.runtime.Worker:460)
[2020-03-23 10:32:13,340] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{com.memsource.kafka.connect.transforms.ExtractDocument$Value} (org.apache.kafka.connect.runtime.Worker:529)
[2020-03-23 10:32:13,341] INFO SinkConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name =
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-task|2020-03-23|1
	tasks.max = 1
	topics = [qa-debezium-comp.converter.task]
	topics.regex =
	transforms = [ExtractDocument]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-03-23 10:32:13,341] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.confluent.connect.s3.S3SinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name =
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	name = tdp-s3-sink-task|2020-03-23|1
	tasks.max = 1
	topics = [qa-debezium-comp.converter.task]
	topics.regex =
	transforms = [ExtractDocument]
	transforms.ExtractDocument.type = class com.memsource.kafka.connect.transforms.ExtractDocument$Value
	value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:32:13,345] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [tdp-qa-cp-kafka-broker-001:9092, tdp-qa-cp-kafka-broker-002:9092, tdp-qa-cp-kafka-broker-003:9092, tdp-qa-cp-kafka-broker-004:9092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-tdp-s3-sink-task|2020-03-23|1-0
	client.rack =
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-tdp-s3-sink-task|2020-03-23|1
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 20000000
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm =
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /etc/kafka/ssl/kafka-connect.truststore.jks
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-03-23 10:32:13,491] INFO Kafka version: 5.4.0-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-03-23 10:32:13,492] INFO Kafka commitId: 9401111f8c4bb0ec (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-03-23 10:32:13,492] INFO Kafka startTimeMs: 1584955933491 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-03-23 10:32:13,499] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125)
[2020-03-23 10:32:13,561] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Subscribed to topic(s): qa-debezium-comp.converter.task (org.apache.kafka.clients.consumer.KafkaConsumer:969)
[2020-03-23 10:32:14,086] INFO S3SinkConnectorConfig values:
	avro.codec = null
	behavior.on.null.values = fail
	connect.meta.data = true
	enhanced.avro.schema.support = false
	filename.offset.zero.pad.width = 10
	flush.size = 15000
	format.bytearray.extension = .bin
	format.bytearray.separator = null
	format.class = class com.memsource.kafka.connect.s3.format.plaintext.PlaintextFormat
	parquet.codec = snappy
	retry.backoff.ms = 5000
	rotate.interval.ms = 3600000
	rotate.schedule.interval.ms = -1
	s3.acl.canned = null
	s3.bucket.name = workspace.ai.eu-west-1.s3.memsource.com
	s3.compression.type = none
	s3.credentials.provider.class = class com.amazonaws.auth.DefaultAWSCredentialsProviderChain
	s3.http.send.expect.continue = true
	s3.part.retries = 3
	s3.part.size = 26214400
	s3.proxy.password = [hidden]
	s3.proxy.url =
	s3.proxy.user = null
	s3.region = eu-west-1
	s3.retry.backoff.ms = 200
	s3.sse.customer.key = [hidden]
	s3.sse.kms.key.id =
	s3.ssea.name =
	s3.wan.mode = false
	schema.cache.size = 1000
	schema.compatibility = NONE
	shutdown.timeout.ms = 3000
 (io.confluent.connect.s3.S3SinkConnectorConfig:347)
[2020-03-23 10:32:14,092] INFO StorageCommonConfig values:
	directory.delim = /
	file.delim = +
	storage.class = class io.confluent.connect.s3.storage.S3Storage
	store.url = null
	topics.dir = 2020-03-01/data/env/qa-test
 (io.confluent.connect.storage.common.StorageCommonConfig:347)
[2020-03-23 10:32:14,094] INFO PartitionerConfig values:
	locale =
	partition.duration.ms = -1
	partition.field.name = []
	partitioner.class = class io.confluent.connect.storage.partitioner.DefaultPartitioner
	path.format =
	timestamp.extractor = Wallclock
	timestamp.field = timestamp
	timezone =
 (io.confluent.connect.storage.partitioner.PartitionerConfig:347)
[2020-03-23 10:32:14,820] INFO Started S3 connector task with assigned partitions: [] (io.confluent.connect.s3.S3SinkTask:116)
[2020-03-23 10:32:14,820] INFO WorkerSinkTask{id=tdp-s3-sink-task|2020-03-23|1-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:302)
[2020-03-23 10:32:14,841] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Cluster ID: zmjn87KhTs63a8CtJau-Qw (org.apache.kafka.clients.Metadata:261)
[2020-03-23 10:32:14,842] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Discovered group coordinator tdp-QA-CP-kafka-broker-002:9092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:756)
[2020-03-23 10:32:14,843] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:32:14,880] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:32:14,905] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Finished assignment for group at generation 1: {connector-consumer-tdp-s3-sink-task|2020-03-23|1-0-45b74a5e-e47e-4f61-aa62-57e87aaffe7b=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@6f750b5d} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:585)
[2020-03-23 10:32:14,940] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:32:14,941] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Adding newly assigned partitions: qa-debezium-comp.converter.task-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:267)
[2020-03-23 10:32:14,953] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Found no committed offset for partition qa-debezium-comp.converter.task-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1241)
[2020-03-23 10:32:14,988] INFO [Consumer clientId=connector-consumer-tdp-s3-sink-task|2020-03-23|1-0, groupId=connect-tdp-s3-sink-task|2020-03-23|1] Resetting offset for partition qa-debezium-comp.converter.task-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385)
[2020-03-23 10:32:14,991] WARN Property 'rotate.interval.ms' is set to '3600000ms' but partitioner is not an instance of 'io.confluent.connect.storage.partitioner.TimeBasedPartitioner'. This property is ignored. (io.confluent.connect.s3.TopicPartitionWriter:129)
[2020-03-23 10:32:15,774] INFO Starting commit and rotation for topic partition qa-debezium-comp.converter.task-0 with start offset {partition=0=155633} (io.confluent.connect.s3.TopicPartitionWriter:277)
[2020-03-23 10:32:15,826] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:984)
[2020-03-23 10:32:15,826] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2020-03-23 10:32:15,826] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533)
[2020-03-23 10:32:15,843] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Successfully joined group with generation 172 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484)
[2020-03-23 10:32:15,844] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Joined group at generation 172 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-87f95b3e-6a0d-4d49-993d-7521bc1d73f2', leaderUrl='http://tdp-QA-kafka-connect-003:10083/', offset=1052, connectorIds=[qa-mongodb-comp-converter-task|2020-02-13|3], taskIds=[tdp-s3-sink-task|2020-03-23|1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540)
[2020-03-23 10:32:15,844] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connectors and tasks using config offset 1052 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104)
[2020-03-23 10:32:15,847] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Starting connector qa-mongodb-comp-converter-task|2020-02-13|3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179)
[2020-03-23 10:32:15,848] INFO ConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-03-23 10:32:15,853] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:32:15,853] INFO Creating connector qa-mongodb-comp-converter-task|2020-02-13|3 of type io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker:251)
[2020-03-23 10:32:15,857] INFO Instantiated connector qa-mongodb-comp-converter-task|2020-02-13|3 with version 0.9.5.Final of type class io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker:254)
[2020-03-23 10:32:16,035] INFO Starting MongoDB connector and discovering replica set(s) at mongodb-001.eu-west-1.qa.memsource.com:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:117)
[2020-03-23 10:32:16,036] INFO Requested thread factory for connector MongoDbConnector, id = qa-debezium-comp named = replica-set-monitor (io.debezium.util.Threads:250)
[2020-03-23 10:32:16,039] INFO Creating thread debezium-mongodbconnector-qa-debezium-comp-replica-set-monitor (io.debezium.util.Threads:267)
[2020-03-23 10:32:16,039] INFO Successfully started MongoDB connector, and continuing to discover changes in replica set(s) at mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:125)
[2020-03-23 10:32:16,046] INFO Finished creating connector qa-mongodb-comp-converter-task|2020-02-13|3 (org.apache.kafka.connect.runtime.Worker:273)
[2020-03-23 10:32:16,051] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:347)
[2020-03-23 10:32:16,051] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:32:16,082] INFO Cluster created with settings {hosts=[mongodb-001.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-003.eu-west-1.qa:27017], mode=MULTIPLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500} (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,085] INFO Adding discovered server mongodb-001.eu-west-1.qa:27017 to client view of cluster (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,120] INFO Adding discovered server mongodb-002.eu-west-1.qa:27017 to client view of cluster (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,125] INFO Adding discovered server mongodb-003.eu-west-1.qa:27017 to client view of cluster (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,129] INFO Files committed to S3. Target commit offset for qa-debezium-comp.converter.task-0 is 244443 (io.confluent.connect.s3.TopicPartitionWriter:514)
[2020-03-23 10:32:16,235] INFO Cluster description not yet available. Waiting for 30000 ms before timing out (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,301] INFO Opened connection [connectionId{localValue:1, serverValue:989409}] to mongodb-001.eu-west-1.qa:27017 (org.mongodb.driver.connection:71)
[2020-03-23 10:32:16,303] INFO Opened connection [connectionId{localValue:3, serverValue:989701}] to mongodb-003.eu-west-1.qa:27017 (org.mongodb.driver.connection:71)
[2020-03-23 10:32:16,309] INFO Opened connection [connectionId{localValue:2, serverValue:1348875}] to mongodb-002.eu-west-1.qa:27017 (org.mongodb.driver.connection:71)
[2020-03-23 10:32:16,350] INFO Monitor thread successfully connected to server with description ServerDescription{address=mongodb-003.eu-west-1.qa:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 6, 10]}, minWireVersion=0, maxWireVersion=6, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=null, roundTripTimeNanos=6294829, setName='qa_set', canonicalAddress=mongodb-003.eu-west-1.qa:27017, hosts=[mongodb-003.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-001.eu-west-1.qa:27017], passives=[], arbiters=[], primary='mongodb-001.eu-west-1.qa:27017', tagSet=TagSet{[]}, electionId=null, setVersion=23, lastWriteDate=Mon Mar 23 10:32:14 CET 2020, lastUpdateTimeNanos=5942926853876516} (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,350] INFO Monitor thread successfully connected to server with description ServerDescription{address=mongodb-001.eu-west-1.qa:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 6, 10]}, minWireVersion=0, maxWireVersion=6, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=null, roundTripTimeNanos=15815221, setName='qa_set', canonicalAddress=mongodb-001.eu-west-1.qa:27017, hosts=[mongodb-003.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-001.eu-west-1.qa:27017], passives=[], arbiters=[], primary='mongodb-001.eu-west-1.qa:27017', tagSet=TagSet{[]}, electionId=7fffffff0000000000000030, setVersion=23, lastWriteDate=Mon Mar 23 10:32:14 CET 2020, lastUpdateTimeNanos=5942926860962010} (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,357] INFO Monitor thread successfully connected to server with description ServerDescription{address=mongodb-002.eu-west-1.qa:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 6, 10]}, minWireVersion=0, maxWireVersion=6, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=null, roundTripTimeNanos=9681054, setName='qa_set', canonicalAddress=mongodb-002.eu-west-1.qa:27017, hosts=[mongodb-003.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-001.eu-west-1.qa:27017], passives=[], arbiters=[], primary='mongodb-001.eu-west-1.qa:27017', tagSet=TagSet{[]}, electionId=null, setVersion=23, lastWriteDate=Mon Mar 23 10:32:14 CET 2020, lastUpdateTimeNanos=5942926862051652} (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,351] INFO Discovered cluster type of REPLICA_SET (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,373] INFO Setting max election id to 7fffffff0000000000000030 from replica set primary mongodb-001.eu-west-1.qa:27017 (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,374] INFO Setting max set version to 23 from replica set primary mongodb-001.eu-west-1.qa:27017 (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,374] INFO Discovered replica set primary mongodb-001.eu-west-1.qa:27017 (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,374] INFO No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=mongodb-003.eu-west-1.qa:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 6, 10]}, minWireVersion=0, maxWireVersion=6, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=null, roundTripTimeNanos=6294829, setName='qa_set', canonicalAddress=mongodb-003.eu-west-1.qa:27017, hosts=[mongodb-003.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-001.eu-west-1.qa:27017], passives=[], arbiters=[], primary='mongodb-001.eu-west-1.qa:27017', tagSet=TagSet{[]}, electionId=null, setVersion=23, lastWriteDate=Mon Mar 23 10:32:14 CET 2020, lastUpdateTimeNanos=5942926853876516}, ServerDescription{address=mongodb-002.eu-west-1.qa:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 6, 10]}, minWireVersion=0, maxWireVersion=6, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=null, roundTripTimeNanos=9681054, setName='qa_set', canonicalAddress=mongodb-002.eu-west-1.qa:27017, hosts=[mongodb-003.eu-west-1.qa:27017, mongodb-002.eu-west-1.qa:27017, mongodb-001.eu-west-1.qa:27017], passives=[], arbiters=[], primary='mongodb-001.eu-west-1.qa:27017', tagSet=TagSet{[]}, electionId=null, setVersion=23, lastWriteDate=Mon Mar 23 10:32:14 CET 2020, lastUpdateTimeNanos=5942926862051652}, ServerDescription{address=mongodb-001.eu-west-1.qa:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out (org.mongodb.driver.cluster:71)
[2020-03-23 10:32:16,419] INFO Opened connection [connectionId{localValue:4, serverValue:989410}] to mongodb-001.eu-west-1.qa:27017 (org.mongodb.driver.connection:71)
[2020-03-23 10:32:16,439] INFO Checking current members of replica set at mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:86)
[2020-03-23 10:32:16,440] INFO Subdividing 1 MongoDB replica set(s) into at most 1 task(s) (io.debezium.connector.mongodb.MongoDbConnector:153)
[2020-03-23 10:32:16,446] INFO Configuring MongoDB connector task 0 to capture events for replica set(s) at qa_set/mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:158)
[2020-03-23 10:32:16,449] INFO Requesting task reconfiguration due to new/removed replica set(s) for MongoDB with seeds mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:133)
[2020-03-23 10:32:16,450] INFO New replica sets include: (io.debezium.connector.mongodb.MongoDbConnector:134)
[2020-03-23 10:32:16,451] INFO   qa_set/mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:135)
[2020-03-23 10:32:16,453] INFO [Worker clientId=connect-1, groupId=tdp-QA-connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125)
[2020-03-23 10:32:16,453] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:347)
[2020-03-23 10:32:16,457] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mongodb.MongoDbConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = qa-mongodb-comp-converter-task|2020-02-13|3
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-03-23 10:32:16,457] INFO Subdividing 1 MongoDB replica set(s) into at most 1 task(s) (io.debezium.connector.mongodb.MongoDbConnector:153)
[2020-03-23 10:32:16,457] INFO Configuring MongoDB connector task 0 to capture events for replica set(s) at qa_set/mongodb-001.eu-west-1.qa:27017,mongodb-002.eu-west-1.qa:27017,mongodb-003.eu-west-1.qa:27017 (io.debezium.connector.mongodb.MongoDbConnector:158)
[2020-03-23 10:32:16,559] INFO Starting commit and rotation for topic partition qa-debezium-comp.converter.task-0 with start offset {partition=0=244444} (io.confluent.connect.s3.TopicPartitionWriter:277)
[2020-03-23 10:32:16,686] INFO Files committed to S3. Target commit offset for qa-debezium-comp.converter.task-0 is 300855 (io.confluent.connect.s3.TopicPartitionWriter:514)