2019-10-22 08:00:57,431 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:00:57,446 - 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:01:57,553 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:01:57,581 - 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:02:57,590 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:02:57,644 - 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:03:57,668 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:03:57,708 - 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:04:54,006 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:04:54,012 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:04:54,029 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 20
2019-10-22 08:04:54,029 - INFO  [DistributedHerder-connect-1:DistributedHerder$RebalanceListener@1397] - [Worker clientId=connect-1, groupId=test-cloud] Joined group at generation 20 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=300000}
2019-10-22 08:04:54,101 - 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:54,101 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:04:57,062 - 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:04:57,098 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:04:57,098 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:04:57,121 - 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,121 - 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-2], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=300000}
2019-10-22 08:04:57,122 - 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,122 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:04:57,928 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:04:57,929 - 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:05:57,966 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:05:58,045 - 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:07:00,874 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:07:01,583 - 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:07:01,687 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:07:01,995 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:07:04,488 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-73f02eff-4002-414d-a321-37995c1281d6 is not valid.
2019-10-22 08:07:05,830 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:07:05,914 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:07:06,360 - 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,360 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:07:06,488 - 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,489 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:08:01,747 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:08:02,938 - 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:04,319 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:09:07,018 - 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:41,919 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:09:50,320 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:09:58,011 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-19ce2604-9c92-4a77-859d-80e2357d0349 is not valid.
2019-10-22 08:09:59,829 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:10:03,548 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:10:09,251 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:10:11,015 - 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:10,500 - 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:12,008 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:10:12,361 - 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:12,460 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:11:12,510 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:11:13,724 - 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:24,439 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:11:29,021 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:11:41,921 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:12:16,866 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:12:19,907 - 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:17,122 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:12:22,631 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-94ba4d90-b4dd-4fa8-bfab-936a080cc605 is not valid.
2019-10-22 08:12:22,631 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:12:22,631 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:12:25,218 - 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:26,715 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:12:27,033 - 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:27,033 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:13:21,717 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:13:23,316 - 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:23,340 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:14:25,750 - 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:21,947 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:15:22,351 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:15:23,038 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-e262dd71-7c92-4009-bd5f-0174ebf42f64 is not valid.
2019-10-22 08:15:23,039 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:15:23,039 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:15:23,472 - 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,473 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:15:23,541 - 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,541 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:15:25,945 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:15:26,152 - 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:26,170 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:16:26,194 - 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:24,065 - 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:24,068 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:17:24,069 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:17:24,089 - 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,091 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:17:24,091 - 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,091 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:17:26,197 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:17:26,197 - 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:26,197 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:18:26,197 - 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:26,198 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:19:26,198 - 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:26,198 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:20:26,199 - 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:26,199 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:21:26,199 - 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:26,204 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:22:26,213 - 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:26,213 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:23:26,214 - 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:26,214 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:24:26,214 - 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:26,215 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:25:26,215 - 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:26,215 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:26:26,216 - 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:26,216 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:27:26,216 - 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:26,217 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:28:26,217 - 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:26,217 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:29:26,221 - 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:26,222 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:30:26,222 - 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:26,222 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:31:26,223 - 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:26,224 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:32:26,224 - 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:26,230 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:33:26,230 - 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:26,233 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:34:26,243 - 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:26,255 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:35:26,283 - 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,257 - INFO  [task-thread-test_cloud-connector-2-0:BinlogReader@458] - 37 records sent during previous 01:38:16.5, last recorded offset: {ts_sec=1571733364, file=mysql-bin.004166, pos=15477888, 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:26,284 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:36:26,284 - 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:26,352 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-2-0} Finished commitOffsets successfully in 68 ms
2019-10-22 08:37:26,355 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:37:26,375 - 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:26,382 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:38:26,397 - 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:26,480 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:39:26,777 - 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:14,040 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:40:26,082 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:40:26,782 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:40:26,974 - 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:27,496 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-ef6c7d02-f083-4d30-91ad-0b44e819d9f3 is not valid.
2019-10-22 08:40:27,497 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:40:27,497 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:40:29,782 - 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:30,874 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:40:31,186 - 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:35,888 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:41:27,314 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:41:30,841 - 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:55,872 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:42:58,171 - 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:57,004 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:43:13,866 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:43:14,771 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-ec641276-0bd6-4e2a-8b43-37fc8fcfad41 is not valid.
2019-10-22 08:43:14,867 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:43:14,867 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:43:16,772 - INFO  [KafkaBasedLog Work Thread - base.test-cloud.config:FetchSessionHandler@442] - [Consumer clientId=consumer-3, groupId=test-cloud] Error sending fetch request (sessionId=1983947133, epoch=161765) to node 0: org.apache.kafka.common.errors.DisconnectException.
2019-10-22 08:43:17,271 - 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,667 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:43:17,884 - 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,884 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:44:12,578 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:44:12,671 - 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:12,675 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:45:12,678 - 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:27,893 - 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:27,930 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:45:27,931 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:45:29,340 - 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,340 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:45:29,359 - 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,361 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:46:12,760 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:46:13,126 - 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:13,345 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:47:15,136 - 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:15,235 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:48:15,258 - 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:15,272 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:49:15,355 - 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:15,534 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:50:15,849 - 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:15,931 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:51:17,039 - 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:20,046 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:52:21,250 - 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:21,532 - INFO  [kafka-coordinator-heartbeat-thread | test-cloud:AbstractCoordinator@780] - [Worker clientId=connect-1, groupId=test-cloud] Group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2019-10-22 08:52:21,643 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$FindCoordinatorResponseHandler@728] - [Worker clientId=connect-1, groupId=test-cloud] Discovered group coordinator 192.168.100.228:9092 (id: 2147483647 rack: null)
2019-10-22 08:52:21,743 - INFO  [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-634f8b04-d6b0-4d76-86a9-937e1243f0e9 is not valid.
2019-10-22 08:52:21,743 - INFO  [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started
2019-10-22 08:52:21,744 - INFO  [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group
2019-10-22 08:52:23,833 - 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:24,038 - 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], taskIds=[test_cloud-connector-2-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0}
2019-10-22 08:52:24,152 - 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:24,152 - INFO  [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks
2019-10-22 08:53:21,333 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:53:21,354 - 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:21,358 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:54:21,373 - 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:21,374 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:55:21,433 - 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:21,456 - INFO  [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-2-0} Finished commitOffsets successfully in 24 ms
2019-10-22 08:56:22,137 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:56:23,047 - 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:23,130 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:57:23,235 - 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:23,244 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:58:23,278 - 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:23,287 - INFO  [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-2-0} Committing offsets
2019-10-22 08:59:23,342 - INFO  [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-2-0} flushing 0 outstanding messages for offset commit