2019-10-22 08:00:53,483 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:00:53,524 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:01:53,529 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:01:53,539 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:02:53,553 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:02:53,650 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:03:53,651 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:03:53,665 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:04:53,667 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:04:53,677 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:04:54,024 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:04:54,024 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:04:57,114 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 21
2019-10-22 08:04:57,115 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 21 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-1], taskIds=[test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=300000}
2019-10-22 08:04:57,118 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:04:57,118 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:05:53,679 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:05:53,685 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:06:53,686 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:06:53,702 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:07:00,219 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:07:00,238 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:07:00,238 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:07:00,330 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 22
2019-10-22 08:07:00,330 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 22 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:07:00,330 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:07:00,384 - INFO  [pool-9-thread-5:DistributedHerder@1075] - [Worker clientId=connect-1, groupId=test-cloud] Starting connector test_cloud-connector-2
2019-10-22 08:07:00,384 - INFO  [pool-9-thread-6:DistributedHerder@1035] - [Worker clientId=connect-1, groupId=test-cloud] Starting task test_cloud-connector-2-0
2019-10-22 08:07:00,384 - INFO  [pool-9-thread-6:Worker@414] - Creating task test_cloud-connector-2-0
2019-10-22 08:07:00,385 - INFO  [pool-9-thread-6:AbstractConfig@347] - ConnectorConfig values: 
2019-10-22 08:07:00,386 - INFO  [pool-9-thread-6:AbstractConfig@347] - EnrichedConnectorConfig values: 
2019-10-22 08:07:00,385 - INFO  [pool-9-thread-5:AbstractConfig@347] - ConnectorConfig values: 
2019-10-22 08:07:00,386 - INFO  [pool-9-thread-5:AbstractConfig@347] - EnrichedConnectorConfig values: 
2019-10-22 08:07:00,386 - INFO  [pool-9-thread-5:Worker@246] - Creating connector test_cloud-connector-2 of type io.debezium.connector.mysql.MySqlConnector
2019-10-22 08:07:00,409 - INFO  [pool-9-thread-6:AbstractConfig@347] - TaskConfig values: 
2019-10-22 08:07:00,428 - INFO  [pool-9-thread-5:Worker@249] - Instantiated connector test_cloud-connector-2 with version 0.10.0.Final of type class io.debezium.connector.mysql.MySqlConnector
2019-10-22 08:07:00,428 - INFO  [pool-9-thread-6:Worker@428] - Instantiated task test_cloud-connector-2-0 with version 0.10.0.Final of type io.debezium.connector.mysql.MySqlConnectorTask
2019-10-22 08:07:00,429 - INFO  [pool-9-thread-6:AbstractConfig@347] - JsonConverterConfig values: 
2019-10-22 08:07:00,429 - INFO  [pool-9-thread-6:Worker@441] - Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task test_cloud-connector-2-0 using the worker config
2019-10-22 08:07:00,429 - INFO  [pool-9-thread-6:AbstractConfig@347] - JsonConverterConfig values: 
2019-10-22 08:07:00,430 - INFO  [pool-9-thread-6:Worker@447] - Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task test_cloud-connector-2-0 using the worker config
2019-10-22 08:07:00,430 - INFO  [pool-9-thread-6:Worker@454] - Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task test_cloud-connector-2-0 using the worker config
2019-10-22 08:07:00,430 - INFO  [pool-9-thread-6:Worker@507] - Initializing: org.apache.kafka.connect.runtime.TransformationChain{}
2019-10-22 08:07:00,431 - INFO  [pool-9-thread-6:AbstractConfig@347] - ProducerConfig values: 
2019-10-22 08:07:00,432 - INFO  [pool-9-thread-5:Worker@268] - Finished creating connector test_cloud-connector-2
2019-10-22 08:07:00,433 - INFO  [pool-9-thread-5:AbstractConfig@347] - SourceConnectorConfig values: 
2019-10-22 08:07:00,433 - INFO  [pool-9-thread-5:AbstractConfig@347] - EnrichedConnectorConfig values: 
2019-10-22 08:07:00,436 - INFO  [pool-9-thread-6:AppInfoParser$AppInfo@117] - Kafka version: 2.3.0
2019-10-22 08:07:00,443 - INFO  [pool-9-thread-6:AppInfoParser$AppInfo@118] - Kafka commitId: fc1aaa116b661c8a
2019-10-22 08:07:00,444 - INFO  [pool-9-thread-6:AppInfoParser$AppInfo@119] - Kafka startTimeMs: 1571731620436
2019-10-22 08:07:00,446 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:07:00,448 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@43] - Starting MySqlConnectorTask with configuration:
2019-10-22 08:07:00,451 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    connector.class = io.debezium.connector.mysql.MySqlConnector
2019-10-22 08:07:00,451 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    snapshot.locking.mode = none
2019-10-22 08:07:00,451 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.user = opser
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.server.id = 222333442
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    tasks.max = 1
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.history.kafka.bootstrap.servers = 192.168.100.228:9092
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.history.kafka.topic = base.history.test_cloud.2
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.server.name = base.server.tc2
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.port = 3306
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    table.whitelist = test_cloud.orders
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    task.class = io.debezium.connector.mysql.MySqlConnectorTask
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    snapshot.new.tables = parallel
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.hostname = rdszde5fhu16qiu8eydir257.mysql.rds.aliyuncs.com
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.password = ********
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    name = test_cloud-connector-2
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.history.store.only.monitored.tables.ddl = true
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    database.whitelist = test_cloud
2019-10-22 08:07:00,452 - INFO  [task-thread-test_cloud-connector-2-0:BaseSourceTask@45] -    snapshot.mode = schema_only
2019-10-22 08:07:00,545 - INFO  [kafka-producer-network-thread | connector-producer-test_cloud-connector-2-0:Metadata@266] - [Producer clientId=connector-producer-test_cloud-connector-2-0] Cluster ID: 0FHlV2RrRTKncKzyiBwQAg
2019-10-22 08:07:00,946 - INFO  [task-thread-test_cloud-connector-2-0:KafkaDatabaseHistory@171] - KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=test_cloud-connector-2-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=192.168.100.228:9092, client.id=test_cloud-connector-2-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1}
2019-10-22 08:07:00,947 - INFO  [task-thread-test_cloud-connector-2-0:KafkaDatabaseHistory@172] - KafkaDatabaseHistory Producer config: {bootstrap.servers=192.168.100.228:9092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=test_cloud-connector-2-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1}
2019-10-22 08:07:00,948 - INFO  [task-thread-test_cloud-connector-2-0:AbstractConfig@347] - ProducerConfig values: 
2019-10-22 08:07:00,951 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@117] - Kafka version: 2.3.0
2019-10-22 08:07:00,951 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@118] - Kafka commitId: fc1aaa116b661c8a
2019-10-22 08:07:00,951 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@119] - Kafka startTimeMs: 1571731620950
2019-10-22 08:07:00,951 - INFO  [task-thread-test_cloud-connector-2-0:MySqlConnectorTask@82] - Found existing offset: {ts_sec=1571731000, file=mysql-bin.004166, pos=13646581, gtids=334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003, row=1, server_id=1687533394, event=2}
2019-10-22 08:07:00,953 - INFO  [task-thread-test_cloud-connector-2-0:AbstractConfig@347] - ConsumerConfig values: 
2019-10-22 08:07:00,956 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@117] - Kafka version: 2.3.0
2019-10-22 08:07:00,957 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@118] - Kafka commitId: fc1aaa116b661c8a
2019-10-22 08:07:00,957 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@119] - Kafka startTimeMs: 1571731620956
2019-10-22 08:07:01,001 - INFO  [task-thread-test_cloud-connector-2-0:Metadata@266] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Cluster ID: 0FHlV2RrRTKncKzyiBwQAg
2019-10-22 08:07:01,013 - INFO  [task-thread-test_cloud-connector-2-0:AbstractConfig@347] - ConsumerConfig values: 
2019-10-22 08:07:01,016 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@117] - Kafka version: 2.3.0
2019-10-22 08:07:01,016 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@118] - Kafka commitId: fc1aaa116b661c8a
2019-10-22 08:07:01,016 - INFO  [task-thread-test_cloud-connector-2-0:AppInfoParser$AppInfo@119] - Kafka startTimeMs: 1571731621016
2019-10-22 08:07:01,016 - INFO  [task-thread-test_cloud-connector-2-0:KafkaConsumer@964] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Subscribed to topic(s): base.history.test_cloud.2
2019-10-22 08:07:01,019 - INFO  [task-thread-test_cloud-connector-2-0:Metadata@266] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Cluster ID: 0FHlV2RrRTKncKzyiBwQAg
2019-10-22 08:07:01,024 - INFO  [task-thread-test_cloud-connector-2-0:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:07:01,103 - INFO  [task-thread-test_cloud-connector-2-0:ConsumerCoordinator@476] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Revoking previously assigned partitions []
2019-10-22 08:07:01,103 - INFO  [task-thread-test_cloud-connector-2-0:AbstractCoordinator@505] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] (Re-)joining group
2019-10-22 08:07:01,106 - INFO  [kafka-producer-network-thread | test_cloud-connector-2-dbhistory:Metadata@266] - [Producer clientId=test_cloud-connector-2-dbhistory] Cluster ID: 0FHlV2RrRTKncKzyiBwQAg
2019-10-22 08:07:01,158 - INFO  [task-thread-test_cloud-connector-2-0:AbstractCoordinator$1@469] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Successfully joined group with generation 1
2019-10-22 08:07:01,201 - INFO  [task-thread-test_cloud-connector-2-0:ConsumerCoordinator@283] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Setting newly assigned partitions: base.history.test_cloud.2-0
2019-10-22 08:07:01,203 - INFO  [task-thread-test_cloud-connector-2-0:ConsumerCoordinator$OffsetFetchResponseHandler@982] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Found no committed offset for partition base.history.test_cloud.2-0
2019-10-22 08:07:01,204 - INFO  [task-thread-test_cloud-connector-2-0:SubscriptionState@348] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Resetting offset for partition base.history.test_cloud.2-0 to offset 0.
2019-10-22 08:07:01,307 - INFO  [task-thread-test_cloud-connector-2-0:AbstractCoordinator@879] - [Consumer clientId=test_cloud-connector-2-dbhistory, groupId=test_cloud-connector-2-dbhistory] Member test_cloud-connector-2-dbhistory-c039cd1c-cc70-445f-b563-338bfc39aa9c sending LeaveGroup request to coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:07:01,315 - INFO  [task-thread-test_cloud-connector-2-0:MySqlConnectorTask@493] - MySQL current GTID set 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2290015,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003 does contain the GTID set required by the connector 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,319 - INFO  [task-thread-test_cloud-connector-2-0:MySqlConnectorTask@498] - GTIDs known by the server but not processed yet 334e1e34-c4ea-11e8-a192-7cd30adfe23c:2289060-2290015, for replication are available only 334e1e34-c4ea-11e8-a192-7cd30adfe23c:2289060-2290015
2019-10-22 08:07:01,323 - INFO  [task-thread-test_cloud-connector-2-0:Threads@250] - Requested thread factory for connector MySqlConnector, id = base.server.tc2 named = binlog-client
2019-10-22 08:07:01,333 - INFO  [task-thread-test_cloud-connector-2-0:BinlogReader@341] - GTID set purged on server: 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2162428,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,333 - INFO  [task-thread-test_cloud-connector-2-0:MySqlTaskContext@300] - Attempting to generate a filtered GTID set
2019-10-22 08:07:01,333 - INFO  [task-thread-test_cloud-connector-2-0:MySqlTaskContext@301] - GTID set from previous recorded offset: 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,333 - INFO  [task-thread-test_cloud-connector-2-0:MySqlTaskContext@308] - GTID set available on server: 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2290015,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,334 - INFO  [task-thread-test_cloud-connector-2-0:MySqlTaskContext@329] - Final merged GTID set to use when connecting to MySQL: 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,334 - INFO  [task-thread-test_cloud-connector-2-0:BinlogReader@346] - Registering binlog reader with GTID set: 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003
2019-10-22 08:07:01,334 - INFO  [task-thread-test_cloud-connector-2-0:Threads$3@267] - Creating thread debezium-mysqlconnector-base.server.tc2-binlog-client
2019-10-22 08:07:01,335 - INFO  [blc-rdszde5fhu16qiu8eydir257.mysql.rds.aliyuncs.com:3306:Threads$3@267] - Creating thread debezium-mysqlconnector-base.server.tc2-binlog-client
2019-10-22 08:07:01,402 - INFO  [blc-rdszde5fhu16qiu8eydir257.mysql.rds.aliyuncs.com:3306:BinlogReader$ReaderThreadLifecycleListener@1027] - Connected to MySQL binlog at rdszde5fhu16qiu8eydir257.mysql.rds.aliyuncs.com:3306, starting at GTIDs 334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2289059,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003 and binlog file 'mysql-bin.004166', pos=13646581, skipping 2 events plus 1 rows
2019-10-22 08:07:01,403 - INFO  [blc-rdszde5fhu16qiu8eydir257.mysql.rds.aliyuncs.com:3306:Threads$3@267] - Creating thread debezium-mysqlconnector-base.server.tc2-binlog-client
2019-10-22 08:07:01,403 - INFO  [task-thread-test_cloud-connector-2-0:WorkerSourceTask@200] - WorkerSourceTask{id=test_cloud-connector-2-0} Source task finished initialization and start
2019-10-22 08:07:06,344 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:07:06,344 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:07:06,344 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:07:06,350 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 23
2019-10-22 08:07:06,351 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 23 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:07:06,351 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:07:06,351 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:07:53,729 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:07:53,733 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:08:00,448 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:08:00,472 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:08:53,733 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:08:53,759 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:09:00,473 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:09:00,473 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:09:21,464 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:09:21,467 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:09:21,467 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:09:21,536 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 24
2019-10-22 08:09:21,537 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 24 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:09:21,537 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:09:21,537 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:09:53,764 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:09:53,770 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:10:00,474 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:10:00,474 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:10:09,563 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:10:09,566 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:10:09,567 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:10:09,577 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 25
2019-10-22 08:10:09,577 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 25 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:10:09,580 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:10:09,580 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:10:53,772 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:10:53,781 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:11:00,474 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:11:00,475 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:11:21,583 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:11:21,585 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:11:21,585 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:11:21,602 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 26
2019-10-22 08:11:21,602 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 26 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:11:21,604 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:11:21,604 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:11:53,782 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:11:53,787 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:12:00,475 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:12:00,475 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:12:06,666 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:12:06,667 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:12:06,667 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:12:06,683 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 27
2019-10-22 08:12:06,683 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 27 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:12:06,685 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:12:06,685 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:12:24,684 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:12:24,684 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:12:24,684 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:12:24,694 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 28
2019-10-22 08:12:24,695 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 28 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:12:24,695 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:12:24,695 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:12:53,789 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:12:53,793 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:13:00,475 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:13:00,476 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:13:53,842 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:13:53,843 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:14:00,476 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:14:00,476 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:14:53,852 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:14:53,859 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:15:00,476 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:15:00,476 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:15:09,784 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:15:09,787 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:15:09,787 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:15:17,454 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 29
2019-10-22 08:15:17,454 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 29 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:15:17,460 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:15:17,460 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:15:23,458 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:15:23,459 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:15:23,459 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:15:23,465 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 30
2019-10-22 08:15:23,466 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 30 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:15:23,466 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:15:23,466 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:15:53,863 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:15:53,882 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:16:00,477 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:16:00,477 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:16:53,884 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:16:53,890 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:17:00,477 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:17:00,477 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:17:23,564 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:17:23,565 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:17:23,565 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:17:24,082 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 31
2019-10-22 08:17:24,082 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 31 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:17:24,083 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:17:24,083 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:17:53,890 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:17:53,897 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:18:00,478 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:18:00,478 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:18:53,899 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:18:53,903 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:19:00,478 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:19:00,478 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:19:53,921 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:19:53,927 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:20:00,479 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:20:00,479 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:20:53,927 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:20:53,936 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:21:00,479 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:21:00,479 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:21:53,936 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:21:53,938 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:22:00,481 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:22:00,481 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:22:53,942 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:22:53,958 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:23:00,481 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:23:00,482 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:23:53,964 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:23:54,011 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:24:00,482 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:24:00,482 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:24:54,014 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:24:54,014 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:25:00,483 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:25:00,483 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:25:54,015 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:25:54,015 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:26:00,483 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:26:00,483 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:26:54,015 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:26:54,016 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:27:00,484 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:27:00,484 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:27:54,016 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:27:54,016 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:28:00,484 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:28:00,484 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:28:54,016 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:28:54,017 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:29:00,485 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:29:00,485 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:29:54,017 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:29:54,017 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:30:00,485 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:30:00,486 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:30:54,018 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:30:54,018 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:31:00,486 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:31:00,486 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:31:54,018 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:31:54,018 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:32:00,486 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:32:00,487 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:32:54,019 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:32:54,019 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:33:00,487 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:33:00,487 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:33:54,020 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:33:54,020 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:34:00,488 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:34:00,488 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:34:54,022 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:34:54,037 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:35:00,489 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:35:00,489 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:35:54,041 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:35:54,060 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:36:00,490 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:36:00,490 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:36:04,324 - INFO  [task-thread-test_cloud-connector-2-0:BinlogReader@458] - 1 records sent during previous 00:29:02.989, last recorded offset: {table_whitelist=test_cloud.orders, ts_sec=1571733364, file=mysql-bin.004166, table_blacklist=null, pos=15477888, database_whitelist=test_cloud, database_blacklist=null, gtids=334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2292630,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003, row=1, server_id=1687533394, event=8}
2019-10-22 08:36:04,416 - INFO  [task-thread-test_cloud-connector-1-0:BinlogReader@458] - 37 records sent during previous 01:38:16.5, last recorded offset: {table_whitelist=test_cloud.orders, ts_sec=1571733364, file=mysql-bin.004166, table_blacklist=null, pos=15477888, database_whitelist=test_cloud, database_blacklist=null, gtids=334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2292630,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003, row=1, server_id=1687533394, event=8}
2019-10-22 08:36:54,061 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:36:54,061 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:36:54,068 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 7 ms
2019-10-22 08:37:00,490 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:37:00,490 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:37:00,493 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-2-0} Finished commitOffsets successfully in 3 ms
2019-10-22 08:37:54,068 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:37:54,069 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:38:00,493 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:38:00,493 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:38:54,069 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:38:54,069 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:39:00,494 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:39:00,494 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:39:46,969 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:39:46,971 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:39:46,971 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:39:46,987 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 32
2019-10-22 08:39:46,987 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 32 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:39:46,987 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:39:46,987 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:39:54,069 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:39:54,070 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:40:00,494 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:40:00,494 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:40:29,031 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:40:29,031 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:40:29,031 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:40:29,036 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 33
2019-10-22 08:40:29,036 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 33 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:40:29,036 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:40:29,036 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:40:54,071 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:40:54,072 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:41:00,495 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:41:00,495 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:41:54,073 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:41:54,073 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:42:00,495 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:42:00,495 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:42:11,156 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:42:11,156 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:42:11,157 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:42:11,165 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 34
2019-10-22 08:42:11,165 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 34 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:42:11,165 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:42:11,165 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:42:54,078 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:42:54,078 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:43:00,496 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:43:00,496 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:43:17,217 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:43:17,217 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:43:17,217 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:43:17,228 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 35
2019-10-22 08:43:17,228 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 35 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:43:17,228 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:43:17,228 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:43:54,079 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:43:54,079 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:44:00,496 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:44:00,496 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:44:54,079 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:44:54,079 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:45:00,497 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:45:00,497 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:45:29,325 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:45:29,325 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:45:29,326 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:45:29,334 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 36
2019-10-22 08:45:29,334 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 36 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:45:29,335 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:45:29,335 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:45:54,080 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:45:54,080 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:46:00,497 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:46:00,497 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:46:54,080 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:46:54,080 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:47:00,498 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:47:00,498 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:47:54,081 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:47:54,081 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:48:00,498 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:48:00,498 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:48:54,081 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:48:54,082 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:49:00,499 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:49:00,499 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:49:54,082 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:49:54,082 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:50:00,499 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:50:00,499 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:50:54,082 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:50:54,083 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:51:00,500 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:51:00,500 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:51:53,682 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:51:53,683 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:51:53,683 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:51:53,688 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 37
2019-10-22 08:51:53,688 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 37 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:51:53,689 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:51:53,689 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:51:54,083 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:51:54,083 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:52:00,500 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:52:00,500 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:52:23,698 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@936] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed since group is rebalancing
2019-10-22 08:52:23,698 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:52:23,698 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:52:23,707 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 38
2019-10-22 08:52:23,708 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 38 and got assignment: Assignment{error=0, leader='connect-1-58ba00dd-41b9-4300-a2fa-3cd6178d400f', leaderUrl='http://10.131.3.89:8083/', offset=9, connectorIds=[test_cloud-connector-2, test_cloud-connector-1], taskIds=[test_cloud-connector-2-0, test_cloud-connector-1-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:52:23,708 - INFO  [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 9
2019-10-22 08:52:23,708 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:52:54,084 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:52:54,116 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:53:00,501 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:53:00,501 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:53:54,119 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:53:54,166 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:54:00,501 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:54:00,501 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:54:42,824 - INFO  [task-thread-test_cloud-connector-2-0:BinlogReader@458] - 8 records sent during previous 00:18:38.5, last recorded offset: {table_whitelist=test_cloud.orders, ts_sec=1571734482, file=mysql-bin.004166, table_blacklist=null, pos=16236367, database_whitelist=test_cloud, database_blacklist=null, gtids=334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-2294321,44dddb9f-f80a-11e6-a449-6c92bf2c17f5:1-60170871,4cef230d-f1e1-11e6-bc1d-10517220497c:1-252840,57b0faaa-f80a-11e6-a449-6c92bf2c1695:1-111060657,73570c5c-212e-11e8-b5e4-70106fada3fa:1-41647797,858c0eef-ffae-11e5-90c8-d89d672b341c:1-1421909,952fa52a-ffae-11e5-90c9-d89d672b35c4:1-783296,b51f5bfe-b5f3-11e6-b555-1051721c3874:1-720857,c4f8369b-b5f3-11e6-b556-1051721c376e:1-534003, row=1, server_id=1687533394, event=2}
2019-10-22 08:54:54,166 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:54:54,167 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:54:54,172 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 5 ms
2019-10-22 08:55:00,502 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:55:00,502 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:55:00,504 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-2-0} Finished commitOffsets successfully in 2 ms
2019-10-22 08:55:54,172 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:55:54,173 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:56:00,505 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:56:00,505 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:56:54,173 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:56:54,173 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:57:00,506 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:57:00,506 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:57:54,173 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:57:54,174 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:58:00,507 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:58:00,507 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:58:54,174 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:58:54,174 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:59:00,510 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:59:00,510 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit
2019-10-22 08:59:54,174 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets
2019-10-22 08:59:54,175 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit