2019-12-31 06:29:50,285 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:29:50,285 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:29:50,292 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 7 ms 2019-12-31 06:30:46,579 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:30:46,579 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:30:50,294 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:30:50,294 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:30:50,366 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 72 ms 2019-12-31 06:31:46,580 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:31:46,580 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:31:50,366 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:31:50,367 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:31:50,368 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 1 ms 2019-12-31 06:32:46,585 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:32:46,585 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:32:50,368 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:32:50,369 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:33:46,585 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:33:46,585 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:33:50,369 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:33:50,369 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:33:50,372 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 3 ms 2019-12-31 06:34:46,585 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:34:46,586 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:34:50,374 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:34:50,374 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:34:50,379 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 5 ms 2019-12-31 06:35:46,586 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:35:46,586 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:35:50,379 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:35:50,379 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:36:46,587 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:36:46,587 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:36:50,380 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:36:50,380 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:36:50,381 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 1 ms 2019-12-31 06:37:46,587 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:37:46,587 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:37:50,382 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:37:50,382 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:37:50,387 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 5 ms 2019-12-31 06:38:46,588 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:38:46,588 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:38:50,389 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:38:50,389 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:38:50,393 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 4 ms 2019-12-31 06:39:46,588 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:39:46,588 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:39:50,396 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:39:50,396 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:40:46,588 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:40:46,589 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:40:50,396 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:40:50,396 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:41:46,590 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:41:46,590 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:41:50,397 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:41:50,397 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:41:50,476 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 79 ms 2019-12-31 06:42:46,590 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:42:46,593 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:42:50,481 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:42:50,481 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:42:50,499 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 18 ms 2019-12-31 06:43:46,593 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:43:46,593 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:43:50,510 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:43:50,510 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:43:50,564 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 54 ms 2019-12-31 06:44:46,594 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:44:46,594 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:44:50,568 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:44:50,568 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:44:50,574 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 6 ms 2019-12-31 06:45:46,595 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:45:46,595 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:45:50,574 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:45:50,574 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:45:50,583 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 9 ms 2019-12-31 06:46:46,595 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:46:46,595 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:46:50,585 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:46:50,585 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:46:50,588 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 3 ms 2019-12-31 06:47:46,596 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:47:46,596 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:47:50,589 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:47:50,589 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:47:50,591 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 2 ms 2019-12-31 06:48:46,598 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:48:46,598 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:48:50,595 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:48:50,595 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:48:50,597 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 2 ms 2019-12-31 06:49:46,600 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:49:46,600 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:49:50,599 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:49:50,599 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:49:50,659 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 60 ms 2019-12-31 06:50:46,603 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:50:46,603 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:50:50,671 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:50:50,672 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:50:50,675 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 3 ms 2019-12-31 06:51:46,604 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:51:46,604 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:51:50,675 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:51:50,675 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:52:46,659 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:52:46,659 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:52:50,675 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:52:50,676 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:53:46,660 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:53:46,660 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:53:50,679 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:53:50,679 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:54:46,663 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:54:46,663 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:54:50,680 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:54:50,680 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:55:46,664 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:55:46,664 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:55:50,680 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:55:50,680 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:56:46,664 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:56:46,664 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:56:50,683 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:56:50,683 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:57:46,664 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:57:46,665 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:57:50,683 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:57:50,684 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:58:46,665 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:58:46,665 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:58:50,685 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:58:50,685 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:59:46,666 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 06:59:46,666 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 06:59:50,686 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 06:59:50,686 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:00:46,666 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:00:46,666 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:00:50,686 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:00:50,686 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:01:46,668 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:01:46,668 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:01:50,687 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:01:50,687 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:02:46,668 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:02:46,668 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:02:50,688 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:02:50,688 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:03:46,669 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:03:46,669 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:03:50,689 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:03:50,689 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:04:46,669 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:04:46,669 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:04:50,689 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:04:50,690 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:05:46,670 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:05:46,670 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:05:50,690 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:05:50,690 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:06:46,670 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:06:46,670 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:06:50,690 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:06:50,690 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:07:46,672 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:07:46,672 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:07:50,693 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:07:50,693 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:08:46,677 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:08:46,677 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:08:50,696 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:08:50,696 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:08:50,764 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 68 ms 2019-12-31 07:09:46,677 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:09:46,678 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:09:50,772 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:09:50,772 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:09:50,779 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 7 ms 2019-12-31 07:10:46,678 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:10:46,678 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:10:50,779 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:10:50,779 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:10:50,781 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 2 ms 2019-12-31 07:11:46,679 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:11:46,679 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:11:50,781 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:11:50,781 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:12:46,680 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:12:46,687 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:12:50,782 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:12:50,782 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:12:50,808 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 26 ms 2019-12-31 07:13:46,688 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:13:46,688 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:13:50,860 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:13:50,860 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:14:46,688 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:14:46,689 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:14:50,860 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:14:50,861 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:15:46,689 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:15:46,689 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:15:50,865 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:15:50,866 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:15:50,867 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 1 ms 2019-12-31 07:16:46,689 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:16:46,689 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:16:50,870 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:16:50,870 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:17:46,690 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:17:46,690 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:17:50,874 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:17:50,874 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:18:46,690 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:18:46,690 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:18:50,875 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:18:50,875 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:19:46,690 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:19:46,691 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:19:50,880 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:19:50,880 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:20:46,692 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:20:46,692 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:20:50,880 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:20:50,880 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:21:46,698 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:21:46,698 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:21:50,881 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:21:50,881 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:22:46,699 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:22:46,699 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:22:50,881 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:22:50,881 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:23:46,700 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:23:46,700 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:23:50,886 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:23:50,886 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:24:46,760 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:24:46,760 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:24:50,886 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:24:50,887 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:24:50,976 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 89 ms 2019-12-31 07:25:46,760 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:25:46,761 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:25:50,977 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:25:50,977 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:26:46,772 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:26:46,772 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:26:50,980 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:26:50,980 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:27:46,772 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:27:46,773 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:27:50,980 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:27:50,981 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:28:46,775 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:28:46,775 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:28:50,987 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:28:50,987 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:28:51,008 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 21 ms 2019-12-31 07:29:46,777 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:29:46,777 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:29:51,009 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:29:51,009 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:30:46,777 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:30:46,777 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:30:51,009 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:30:51,009 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:31:46,779 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:31:46,779 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:31:51,059 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:31:51,059 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:32:46,779 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:32:46,779 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:32:51,059 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:32:51,060 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:33:46,781 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:33:46,781 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:33:51,060 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:33:51,060 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:33:51,088 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 28 ms 2019-12-31 07:34:46,781 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:34:46,782 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:34:51,096 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:34:51,096 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:35:46,783 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:35:46,783 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:35:51,159 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:35:51,159 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:36:46,785 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:36:46,785 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:36:51,159 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:36:51,160 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:37:46,788 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:37:46,789 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:37:51,160 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:37:51,160 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:38:46,790 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:38:46,790 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:38:51,160 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:38:51,161 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:39:46,792 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:39:46,793 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:39:51,161 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:39:51,161 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:40:46,794 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:40:46,794 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:40:51,162 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:40:51,162 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:41:46,796 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:41:46,796 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:41:51,168 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:41:51,168 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:42:46,796 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:42:46,796 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:42:51,168 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:42:51,169 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:43:46,797 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:43:46,797 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:43:51,169 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:43:51,169 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:44:46,797 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:44:46,797 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:44:51,169 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:44:51,170 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:45:46,798 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:45:46,798 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:45:51,170 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:45:51,170 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:46:46,798 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:46:46,799 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:46:51,171 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:46:51,171 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:47:46,801 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:47:46,801 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:47:51,175 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:47:51,175 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:48:46,802 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:48:46,802 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:48:51,176 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:48:51,176 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:49:46,802 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:49:46,803 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:49:51,176 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:49:51,176 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:50:46,860 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:50:46,860 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:50:51,176 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:50:51,177 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:51:46,868 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:51:46,868 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:51:51,177 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:51:51,178 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:52:46,871 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:52:46,871 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:52:51,181 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:52:51,181 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:53:46,876 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:53:46,876 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:53:51,182 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:53:51,182 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:54:46,880 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:54:46,880 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:54:51,184 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:54:51,184 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:55:46,880 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:55:46,881 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:55:51,184 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:55:51,184 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:56:46,887 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:56:46,887 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:56:51,184 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:56:51,185 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:57:46,887 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:57:46,887 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:57:51,186 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:57:51,186 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:58:46,888 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:58:46,888 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:58:51,197 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:58:51,197 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:59:46,889 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 07:59:46,889 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 07:59:51,197 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 07:59:51,197 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:00:46,890 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:00:46,890 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:00:51,198 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:00:51,198 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:01:46,890 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:01:46,890 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:01:51,198 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:01:51,198 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:02:46,890 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:02:46,891 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:02:51,199 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:02:51,199 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:03:46,898 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:03:46,898 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:03:51,200 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:03:51,259 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:04:46,899 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:04:46,899 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:04:51,260 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:04:51,260 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:05:46,900 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:05:46,900 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:05:51,260 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:05:51,260 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:06:46,902 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:06:46,902 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:06:51,261 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:06:51,261 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:07:46,902 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:07:46,903 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:07:51,261 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:07:51,261 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:08:04,893 - INFO [task-thread-test_cloud-connector-1-0:BinlogReader@465] - 832 records sent during previous 02:09:13.002, last recorded offset: {table_whitelist=test_cloud.orders,test_cloud.test_debezium_1, ts_sec=1577779684, file=mysql-bin.004475, table_blacklist=null, pos=15432381, database_whitelist=test_cloud, database_blacklist=null, gtids=334e1e34-c4ea-11e8-a192-7cd30adfe23c:1-21554402,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-12-31 08:08:46,959 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:08:46,959 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:08:51,261 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:08:51,262 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:08:51,272 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 10 ms 2019-12-31 08:09:46,959 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:09:46,959 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:09:51,281 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:09:51,281 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:10:46,960 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:10:46,960 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:10:51,285 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:10:51,285 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:10:51,297 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 12 ms 2019-12-31 08:11:46,964 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:11:46,964 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:11:51,297 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:11:51,298 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:11:51,313 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 15 ms 2019-12-31 08:12:46,964 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:12:46,965 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:12:51,313 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:12:51,313 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:12:51,361 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 48 ms 2019-12-31 08:13:46,965 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:13:46,965 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:13:51,364 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:13:51,364 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:14:46,968 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:14:46,969 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:14:51,365 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:14:51,365 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:15:46,971 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:15:46,971 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:15:51,365 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:15:51,365 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:16:46,973 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:16:46,973 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:16:51,366 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:16:51,366 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:17:46,974 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:17:46,974 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:17:51,369 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:17:51,369 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:18:46,975 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:18:46,975 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:18:51,370 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:18:51,370 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:19:46,979 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:19:46,979 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:19:51,371 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:19:51,371 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:20:46,980 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:20:46,980 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:20:51,371 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:20:51,372 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:21:46,982 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:21:46,982 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:21:51,372 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:21:51,372 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:22:46,983 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:22:46,983 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:22:51,373 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:22:51,373 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:23:46,986 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:23:46,986 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:23:51,373 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:23:51,374 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:24:46,987 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:24:46,987 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:24:51,375 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:24:51,375 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:25:46,989 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:25:46,989 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:25:51,384 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:25:51,384 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:26:46,989 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:26:46,990 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:26:51,384 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:26:51,385 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:27:46,992 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:27:46,992 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:27:51,389 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:27:51,389 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:28:46,998 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:28:46,999 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:28:51,390 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:28:51,390 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:29:46,999 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:29:46,999 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:29:51,391 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:29:51,391 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:30:46,999 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:30:46,999 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:30:51,392 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:30:51,392 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:31:47,000 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:31:47,000 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:31:51,393 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:31:51,393 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:32:47,000 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:32:47,000 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:32:51,394 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:32:51,394 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:33:47,002 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:33:47,002 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:33:51,394 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:33:51,394 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:34:47,002 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:34:47,003 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:34:51,394 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:34:51,395 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:35:47,003 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:35:47,008 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:35:51,395 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:35:51,395 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:36:47,008 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:36:47,061 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:36:51,398 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:36:51,398 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:37:47,062 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:37:47,062 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:37:51,401 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:37:51,401 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:38:47,065 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:38:47,065 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:38:51,401 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:38:51,401 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:39:47,071 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:39:47,183 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:39:51,403 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:39:51,403 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:40:47,183 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:40:47,187 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:40:51,403 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:40:51,403 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:41:47,188 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:41:47,288 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:41:51,404 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:41:51,404 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:42:47,291 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:42:47,291 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:42:51,404 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:42:51,404 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:43:47,292 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:43:47,294 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:43:51,405 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:43:51,471 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:44:47,294 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:44:47,359 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:44:51,475 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:44:51,475 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:45:47,366 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:45:47,465 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:45:51,480 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:45:51,480 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:46:47,465 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:46:47,482 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:46:51,481 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:46:51,481 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:47:21,896 - 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-12-31 08:47:25,194 - 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-12-31 08:47:25,279 - INFO [DistributedHerder-connect-1:AbstractCoordinator$HeartbeatResponseHandler@947] - [Worker clientId=connect-1, groupId=test-cloud] Attempt to heartbeat failed for since member id connect-1-0a1fe0ea-b094-4ac3-bab1-5354b6ca9fa6 is not valid. 2019-12-31 08:47:25,284 - INFO [DistributedHerder-connect-1:WorkerCoordinator@213] - [Worker clientId=connect-1, groupId=test-cloud] Rebalance started 2019-12-31 08:47:25,284 - INFO [DistributedHerder-connect-1:AbstractCoordinator@505] - [Worker clientId=connect-1, groupId=test-cloud] (Re-)joining group 2019-12-31 08:47:27,847 - INFO [DistributedHerder-connect-1:AbstractCoordinator$1@469] - [Worker clientId=connect-1, groupId=test-cloud] Successfully joined group with generation 34 2019-12-31 08:47:27,865 - 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-86dfdcd3-25ac-4064-86f0-6b1f25dd86bf', leaderUrl='http://10.128.1.128:8083/', offset=66, connectorIds=[test_cloud-connector-1, test_cloud-connector-3], taskIds=[test_cloud-connector-1-0, test_cloud-connector-3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} 2019-12-31 08:47:27,890 - INFO [DistributedHerder-connect-1:DistributedHerder@1000] - [Worker clientId=connect-1, groupId=test-cloud] Starting connectors and tasks using config offset 66 2019-12-31 08:47:27,891 - INFO [DistributedHerder-connect-1:DistributedHerder@1021] - [Worker clientId=connect-1, groupId=test-cloud] Finished starting connectors and tasks 2019-12-31 08:47:42,070 - INFO [KafkaBasedLog Work Thread - base.test-cloud.status:FetchSessionHandler@442] - [Consumer clientId=consumer-2, groupId=test-cloud] Error sending fetch request (sessionId=11693723, epoch=1772883) to node 0: org.apache.kafka.common.errors.DisconnectException. 2019-12-31 08:47:47,485 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:47:47,485 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:47:51,484 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:47:51,484 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:48:47,486 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:48:47,572 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:48:51,485 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:48:51,485 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:49:47,573 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:49:47,573 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:49:51,485 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:49:51,485 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:50:47,573 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:50:47,583 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:50:51,486 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:50:51,486 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:51:47,583 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:51:47,874 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:51:51,494 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:51:51,494 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:51:51,794 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 300 ms 2019-12-31 08:52:47,878 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:52:47,883 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:52:51,859 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:52:51,859 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:53:47,889 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:53:47,906 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:53:51,861 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:53:51,861 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:54:47,906 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:54:47,995 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:54:51,862 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:54:51,862 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:55:47,996 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:55:47,999 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:55:51,863 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:55:51,863 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:55:51,886 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 23 ms 2019-12-31 08:56:47,999 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:56:48,093 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:56:51,890 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:56:51,890 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:56:51,962 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 72 ms 2019-12-31 08:57:48,100 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:57:48,104 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:57:51,964 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:57:51,964 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:58:48,105 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:58:48,176 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:58:51,965 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:58:51,965 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:59:48,176 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 08:59:48,179 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:59:51,965 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 08:59:51,966 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 08:59:51,990 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 24 ms 2019-12-31 09:00:48,179 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:00:48,181 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:00:51,997 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:00:51,997 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:00:52,062 - INFO [pool-10-thread-1:WorkerSourceTask@497] - WorkerSourceTask{id=test_cloud-connector-1-0} Finished commitOffsets successfully in 65 ms 2019-12-31 09:01:48,182 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:01:48,183 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:01:52,062 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:01:52,062 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:02:48,184 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:02:48,184 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:02:52,063 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:02:52,063 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:03:48,189 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:03:48,189 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:03:52,066 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:03:52,066 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:04:48,192 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:04:48,192 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:04:52,066 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:04:52,066 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:05:48,259 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:05:48,259 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:05:52,068 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:05:52,068 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:06:48,259 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:06:48,372 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:06:52,069 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:06:52,070 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:07:48,375 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:07:48,376 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:07:52,074 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:07:52,074 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:08:48,377 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:08:48,377 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:08:52,075 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:08:52,075 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:09:48,377 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:09:48,377 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:09:52,075 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:09:52,075 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:10:48,378 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:10:48,378 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:10:52,075 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:10:52,076 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:11:48,396 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:11:48,396 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:11:52,076 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:11:52,076 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:12:48,396 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:12:48,463 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:12:52,076 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:12:52,077 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:13:48,463 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:13:48,464 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:13:52,078 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:13:52,078 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:14:48,464 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:14:48,464 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:14:52,079 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:14:52,079 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:15:14,270 - INFO [KafkaBasedLog Work Thread - base.test-cloud.config:DistributedHerder$ConfigUpdateListener@1302] - [Worker clientId=connect-1, groupId=test-cloud] Connector test_cloud-connector-3 target state change 2019-12-31 09:15:14,272 - INFO [DistributedHerder-connect-1:Worker@791] - Setting connector test_cloud-connector-3 state to PAUSED 2019-12-31 09:15:48,464 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:15:48,475 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:15:52,081 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:15:52,081 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:16:48,476 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:16:48,490 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:16:52,081 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:16:52,081 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:17:48,490 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:17:48,494 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:17:52,082 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:17:52,082 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:18:48,494 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:18:48,507 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:18:52,082 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:18:52,083 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:19:48,507 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:19:48,520 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:19:52,083 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:19:52,083 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:20:48,520 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:20:48,521 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:20:52,084 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:20:52,084 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:21:48,522 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:21:48,522 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:21:52,084 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:21:52,084 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:22:48,522 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:22:48,527 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:22:52,086 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:22:52,086 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:23:48,530 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:23:48,544 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:23:52,089 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:23:52,089 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:24:48,545 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:24:48,551 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:24:52,091 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:24:52,091 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:25:48,551 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:25:48,555 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:25:52,091 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-1-0} Committing offsets 2019-12-31 09:25:52,092 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-1-0} flushing 0 outstanding messages for offset commit 2019-12-31 09:26:48,556 - INFO [pool-10-thread-1:WorkerSourceTask@398] - WorkerSourceTask{id=test_cloud-connector-3-0} Committing offsets 2019-12-31 09:26:48,613 - INFO [pool-10-thread-1:WorkerSourceTask@415] - WorkerSourceTask{id=test_cloud-connector-3-0} flushing 0 outstanding messages for offset commit