[2021-08-20 13:42:29,596] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:42:29,597] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:42:29,597] INFO WorkerSourceTask{id=GE_prod-0} flushing 61568 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:42:29,598] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:42:29,598] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:42:29,699] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:42:29,703] INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-09879ecd-e7fa-4b86-9a71-4611d4ae6f03 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1065)
[2021-08-20 13:42:29,703] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2021-08-20 13:42:29,703] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:42:32,708] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 60 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503)
[2021-08-20 13:42:32,709] WARN [Worker clientId=connect-1, groupId=connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1020)
[2021-08-20 13:42:32,709] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 940 is behind group assignment 941, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 13:42:32,743] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 941 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1085)
[2021-08-20 13:42:32,743] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 941 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1111)
[2021-08-20 13:42:32,743] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1132)
[2021-08-20 13:42:34,598] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 59598 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:42:34,598] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:42:51,009] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:42:51,010] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:42:51,011] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:42:51,118] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:42:51,123] INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-e484f0e2-8122-4a4e-87d1-f9762f59d809 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1065)
[2021-08-20 13:42:51,123] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2021-08-20 13:42:51,123] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:42:54,127] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 62 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503)
[2021-08-20 13:42:54,127] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 941 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1111)
[2021-08-20 13:42:54,128] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1132)
[2021-08-20 13:42:54,528] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1889338796, epoch=189): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:43:05,757] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:43:05,759] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:43:05,760] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:43:05,860] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:43:05,865] INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-1fd0e786-ea6d-4080-823a-e71b524945c2 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1065)
[2021-08-20 13:43:05,866] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2021-08-20 13:43:05,866] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:43:20,469] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1440193451, epoch=162): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:43:20,471] INFO [Worker clientId=connect-1, groupId=connect-cluster] Join group failed with org.apache.kafka.common.errors.UnknownMemberIdException: The coordinator is not aware of this member. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
[2021-08-20 13:43:20,472] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:43:34,909] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:43:34,910] INFO WorkerSourceTask{id=GE_prod-0} flushing 53737 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:43:34,914] INFO [Worker clientId=connect-1, groupId=connect-cluster] Join group failed with org.apache.kafka.common.errors.UnknownMemberIdException: The coordinator is not aware of this member. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
[2021-08-20 13:43:34,914] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:43:47,809] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 53352 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:43:47,810] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:43:47,813] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 68 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503)
[2021-08-20 13:43:47,814] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 941 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1111)
[2021-08-20 13:43:47,815] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1132)
[2021-08-20 13:43:47,878] INFO [Worker clientId=connect-1, groupId=connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1447)
[2021-08-20 13:43:58,226] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:43:58,227] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:43:58,228] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:43:58,329] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:43:58,336] INFO [Worker clientId=connect-1, groupId=connect-cluster] Attempt to heartbeat failed for since member id connect-1-c0eac8a0-dc89-47c0-a9fe-c8fadeaa4207 is not valid. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1065)
[2021-08-20 13:43:58,336] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2021-08-20 13:43:58,336] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:44:08,084] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 70 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503)
[2021-08-20 13:44:08,085] WARN [Worker clientId=connect-1, groupId=connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1020)
[2021-08-20 13:44:08,086] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 941 is behind group assignment 942, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 13:44:18,419] INFO [Worker clientId=connect-1, groupId=connect-cluster] Group coordinator kfk02:6667 (id: 2147482646 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:849)
[2021-08-20 13:44:18,419] WARN [Worker clientId=connect-1, groupId=connect-cluster] Didn't reach end of config log quickly enough (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1090)
java.util.concurrent.TimeoutException: Timed out waiting for future
	at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:106)
	at org.apache.kafka.connect.storage.KafkaConfigBackingStore.refresh(KafkaConfigBackingStore.java:412)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.readConfigToEnd(DistributedHerder.java:1083)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.handleRebalanceCompleted(DistributedHerder.java:1039)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:317)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:289)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
[2021-08-20 13:44:18,420] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=702276761, epoch=49): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:44:35,543] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=1111350034, epoch=45): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:44:35,543] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=624299016, epoch=48): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:44:55,494] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:44:55,495] INFO WorkerSourceTask{id=GE_prod-0} flushing 52328 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:45:04,382] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 52328 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:45:04,383] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:45:04,383] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1707015973, epoch=22): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:45:28,759] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=2123397501, epoch=20): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:46:10,393] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:46:10,394] INFO WorkerSourceTask{id=GE_prod-0} flushing 51943 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:46:19,688] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 51908 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:46:19,689] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=245324557, epoch=16): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:46:19,689] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:46:38,396] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=658901660, epoch=14): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:47:22,262] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:47:22,263] INFO WorkerSourceTask{id=GE_prod-0} flushing 51657 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:47:30,078] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 51628 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:47:30,079] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:47:41,353] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=488977656, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:48:36,297] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:48:36,298] INFO WorkerSourceTask{id=GE_prod-0} flushing 51383 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:48:36,298] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1284241614, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:48:36,298] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1070432472, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:48:46,180] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 51383 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:48:46,182] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:49:04,971] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=402432873, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:49:22,422] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 941 is behind group assignment 942, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 13:49:22,422] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=1760902376, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:49:22,424] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 942 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1085)
[2021-08-20 13:49:31,484] INFO [Worker clientId=connect-1, groupId=connect-cluster] Wasn't able to resume work after last rebalance, can skip stopping connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1638)
[2021-08-20 13:49:48,387] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:49:48,390] INFO WorkerSourceTask{id=GE_prod-0} flushing 51138 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:49:57,781] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 51103 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:49:57,782] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:50:32,232] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator kfk02:6667 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:797)
[2021-08-20 13:50:32,247] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222)
[2021-08-20 13:50:32,248] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:51:01,520] INFO [Worker clientId=connect-1, groupId=connect-cluster] Join group failed with org.apache.kafka.common.errors.UnknownMemberIdException: The coordinator is not aware of this member. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
[2021-08-20 13:51:01,521] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:552)
[2021-08-20 13:51:01,523] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:51:01,524] INFO WorkerSourceTask{id=GE_prod-0} flushing 50891 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:51:11,449] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 50821 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:51:11,450] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:51:11,453] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 74 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:503)
[2021-08-20 13:51:11,453] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 74 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-02e0ead4-311b-4bb6-a748-05e2357d5835', leaderUrl='http://*.*.*.*:8083/', offset=942, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=276011} with rebalance delay: 276011 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1549)
[2021-08-20 13:51:20,387] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 942 is behind group assignment 942, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 13:51:27,953] WARN [Worker clientId=connect-1, groupId=connect-cluster] Didn't reach end of config log quickly enough (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1090)
java.util.concurrent.TimeoutException: Timed out waiting for future
	at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:106)
	at org.apache.kafka.connect.storage.KafkaConfigBackingStore.refresh(KafkaConfigBackingStore.java:412)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.readConfigToEnd(DistributedHerder.java:1083)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:312)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:289)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
[2021-08-20 13:51:27,955] INFO [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-02e0ead4-311b-4bb6-a748-05e2357d5835 sending LeaveGroup request to coordinator kfk02:6667 (id: 2147482646 rack: null) due to taking too long to read the log (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:979)
[2021-08-20 13:51:52,181] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=257218574, epoch=12): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:52:17,859] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:52:17,860] INFO WorkerSourceTask{id=GE_prod-0} flushing 50539 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:52:28,334] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 50539 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:52:28,335] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:52:48,385] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=576480451, epoch=15): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:53:17,870] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=165285696, epoch=14): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:53:29,731] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:53:29,732] INFO WorkerSourceTask{id=GE_prod-0} flushing 50329 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:53:39,324] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 50294 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:53:46,333] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1553116426, epoch=12): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:53:46,334] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=2124247441, epoch=12): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:53:46,334] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:53:54,243] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1201809980, epoch=12): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:54:48,384] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:54:48,384] INFO WorkerSourceTask{id=GE_prod-0} flushing 50014 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:54:56,524] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 50014 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:54:56,525] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=636667386, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:54:56,526] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:55:18,898] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=117208161, epoch=12): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:55:49,016] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1209592176, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:55:49,016] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=421272643, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:55:56,863] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:55:56,864] INFO WorkerSourceTask{id=GE_prod-0} flushing 49767 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:55:56,864] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=778507719, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:56:04,843] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 49767 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:56:04,844] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:56:33,762] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 942 is behind group assignment 942, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 13:56:42,730] WARN [Worker clientId=connect-1, groupId=connect-cluster] Didn't reach end of config log quickly enough (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1090)
java.util.concurrent.TimeoutException: Timed out waiting for future
	at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:106)
	at org.apache.kafka.connect.storage.KafkaConfigBackingStore.refresh(KafkaConfigBackingStore.java:412)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.readConfigToEnd(DistributedHerder.java:1083)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:312)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:289)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
[2021-08-20 13:57:09,802] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:57:09,803] INFO WorkerSourceTask{id=GE_prod-0} flushing 49522 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:57:09,804] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=1388255560, epoch=14): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:57:17,774] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 49487 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:57:17,775] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
[2021-08-20 13:58:00,613] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1001 was unable to process the fetch request with (sessionId=1556965033, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:58:25,630] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 13:58:25,630] INFO WorkerSourceTask{id=GE_prod-0} flushing 49207 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 13:58:35,695] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 49207 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 13:58:51,280] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1817965332, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:58:51,280] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=1846246631, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:58:51,279] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Node 1002 was unable to process the fetch request with (sessionId=2024980853, epoch=13): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler:403)
[2021-08-20 13:58:58,060] ERROR WorkerSourceTask{id=GE_prod-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:116)
java.lang.OutOfMemoryError: Java heap space
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:12:58,514] INFO WorkerSourceTask{id=GE_prod-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424)
[2021-08-20 14:12:51,429] WARN Could not stop task (org.apache.kafka.connect.runtime.WorkerSourceTask:?)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:12:51,430] ERROR Uncaught exception in thread 'kafka-producer-network-thread | producer-2': (org.apache.kafka.common.utils.KafkaThread:51)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:12:38,104] ERROR Uncaught exception in thread 'kafka-producer-network-thread | producer-3': (org.apache.kafka.common.utils.KafkaThread:51)
java.lang.OutOfMemoryError: Java heap space
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:12:38,103] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:02:08,615] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset 942 is behind group assignment 942, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1081)
[2021-08-20 14:01:46,561] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Error sending fetch request (sessionId=1928869527, epoch=6) to node 1001: {}. (org.apache.kafka.clients.FetchSessionHandler:481)
org.apache.kafka.common.errors.DisconnectException
[2021-08-20 14:01:30,702] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Error sending fetch request (sessionId=2046610655, epoch=3) to node 1002: {}. (org.apache.kafka.clients.FetchSessionHandler:481)
org.apache.kafka.common.errors.DisconnectException
[2021-08-20 14:16:29,524] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:109)
[2021-08-20 14:16:29,525] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:60)
[2021-08-20 14:16:29,517] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:86)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:16:29,516] INFO WorkerSourceTask{id=GE_prod-0} flushing 48997 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441)
[2021-08-20 14:16:29,526] ERROR WorkerSourceTask{id=GE_prod-0} Failed to flush, timed out while waiting for producer to flush outstanding 48997 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:446)
[2021-08-20 14:16:29,539] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:187)
[2021-08-20 14:16:29,539] ERROR WorkerSourceTask{id=GE_prod-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:186)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:16:29,539] ERROR WorkerSourceTask{id=GE_prod-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:187)
[2021-08-20 14:16:29,526] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31)
java.lang.OutOfMemoryError: Java heap space
[2021-08-20 14:16:29,525] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Error sending fetch request (sessionId=1053865441, epoch=7) to node 1001: {}. (org.apache.kafka.clients.FetchSessionHandler:481)
org.apache.kafka.common.errors.DisconnectException
[2021-08-20 14:16:29,540] INFO startScn=915514896606, endScn=915514996606 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:160)
[2021-08-20 14:16:29,542] INFO Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=916618416395, oldestScn=915503714298, committedScn=915514975797, offsetScn=915503569606, logMinerQueryCount=293, totalProcessedRows=2836258, totalCapturedDmlCount=2545569, totalDurationOfFetchingQuery=PT17M36.499S, lastCapturedDmlCount=130704, lastDurationOfFetchingQuery=PT2.034S, maxCapturedDmlCount=418442, maxDurationOfFetchingQuery=PT1M18.879S, totalBatchProcessingDuration=PT0S, lastBatchProcessingDuration=PT0S, maxBatchProcessingDuration=PT0S, maxBatchProcessingThroughput=0, currentLogFileName=[Ljava.lang.String;@6eaf1944, minLogFilesMined=0, maxLogFilesMined=2, redoLogStatus=[Ljava.lang.String;@c2cf22a, switchCounter=27, batchSize=99000, millisecondToSleepBetweenMiningQuery=0, hoursToKeepTransaction=1, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT13M28.095S, totalStartLogMiningSessionDuration=PT29.366S, lastStartLogMiningSessionDuration=PT0.004S, maxStartLogMiningSessionDuration=PT28.849S, totalProcessTime=PT18M19.95S, minBatchProcessTime=PT0S, maxBatchProcessTime=PT0S, totalResultSetNextTime=PT23M30.994S, lagFromTheSource=DurationPT76H36M39.621S, maxLagFromTheSourceDuration=PT76H36M39.621S, minLagFromTheSourceDuration=PT0S, lastCommitDuration=PT0S, maxCommitDuration=PT22M51.978S, activeTransactions=8, rolledBackTransactions=997, committedTransactions=24852, abandonedTransactionIds=[], rolledbackTransactionIds=[040015006d741a00, 270005003f7b1c00, 11001c00173c1b00, 34001800c50f1c00, 4a001700df910100, 29000000bbfe1c00, 31000a00451a1e00, 0f0010007fc51a00, 4f000e00126d0100, 25000200a4d81b00, 3a001a0092142300, 24001d00478d1c00, 150010009b0a1c00, 0d0011005f5b1b00, 36001700b27d1d00, 4b001700af8a0100, 29000d0008001d00, 4b000300bf8a0100, 32000200886e1f00, 240016003f8d1c00, 2b001d007a961d00, 26000d00bd781c00, 3c00060025ba1600, 26001600de791c00, 2f0011009e301e00, 2c001200e0d41e00, 47001500f9430200, 1900030017f81c00, 3b00030039291c00, 29001f0060ff1c00, 2d0010006d7e2000, 3b000600e6291c00, 260013006f781c00, 27000a005c7d1c00, 250006003fd71b00, 36001700a47d1d00, 120006004b761b00, 4900130058630200, 42001400a0df0700, 1700040007381c00, 3b0001007f2a1c00, 020001003c8f1a00, 48000400b65f0200, 29000b00b5fd1c00, 21001c00ab241d00, 22001000517a1e00, 3b001c000f2a1c00, 27001900717b1c00, 2b001b009e951d00, 0f000f004ec71a00, 14001c00cf251b00, 21001d004a211d00, 24001c008b8c1c00, 0e0011005f491b00, 3f000500c03c1100, 49001800f9620200, 240007009e8c1c00, 42000a0086e00700, 3700170047e31e00, 2d000f00db7e2000, 2d000400bc7b2000, 42001f006ce00700, 13000000fcda1a00, 13001a0044dd1a00, 34000100ea101c00, 0a000e0038331b00, 040017008b751a00, 34000d00e7101c00, 3a001600f0152300, 1b001c00f9151e00, 13002100c8dc1a00, 44000900ba140500, 24001000098c1c00, 0300060067001b00, 31000b00f01a1e00, 1700060017381c00, 3f0013006f3d1100, 4000210013ac0e00, 04000000da741a00, 2a000a0092de1d00, 100018006f351b00, 27001600c27b1c00, 0c00160037d81a00, 32000400c46f1f00, 2b000100b9951d00, 29001d0038ff1c00, 12002100a6751b00, 22000e0093791e00, 38000500dfdc2100, 36000000ac801d00, 42001f00b4e00700, 3400170048101c00, 36000600507d1d00, 08000800d2a51a00, 0d00090009591b00, 0a000400962d1b00, 09001d00fbbd1a00, 1a0018007e3e1d00, 47002100a7430200, 46001a00378b0200, 0d000f00e5581b00, 3e001300b6cf1200, 2d000400a47b2000, 2c000500fad41e00, 26001400017b1c00, 3d000c007b741200, 21000f0069261d00, 2000200025bc2100, 3a001700e5142300, 2d000600a17d2000, 2a00190036dc1d00, 45000a000a500300, 34000b0004111c00, 0e0010006f481b00, 2a00060052de1d00, 1b0017002a161e00, 4e000800d8630100, 4900150009630200, 1900020069f81c00, 3700030060e41e00, 27000a003b7d1c00, 16000b008ada1b00, 1b00130038161e00, 4a000d00b6910100, 1400120002241b00, 3a0014001b162300, 09000c00adbd1a00, 30001a0090621d00, 09001000a9be1a00, 42001500addf0700, 0c000e0082d71a00, 3200030012701f00, 19001700d6fa1c00, 1e0006000e711e00, 0f00160092c81a00, 31001c002a1a1e00, 3c000000afba1600, 25000c00c6d61b00, 030016004d001b00, 40000a000dac0e00, 420002006ce00700, 1b001800230d1e00, 4a00110015910100, 22001600407b1e00, 4f001e00106d0100, 3d00010072751200, 32000b00966f1f00, 2f000c005e2e1e00, 100007006d341b00, 24000600758d1c00, 1200190092761b00, 1c000300e0851f00, 4500030032500300, 21001400f4241d00, 110018005b3c1b00, 0e001f0075491b00, 27001100eb7a1c00, 2c000f0036d51e00, 2f000600ad301e00, 0d0019005e591b00, 38001e002fda2100, 31000200fd1a1e00, 4000020001ad0e00, 06000100a6011a00, 350020002fb91b00, 1b001d001b161e00, 36000a002c7f1d00, 3a001000ba132300, 3b0008001a291c00, 0e001f0055491b00, 20000d00b9bc2100, 27001f00967c1c00, 2b001b00a0951d00, 3d001c00aa741200, 3c001e0069ba1600, 09001a0057be1a00, 02001e006a8e1a00, 29000d0012001d00, 01000b00098e1b00, 45001e00734f0300, 18001d00e4501c00, 21001d0066211d00, 48000b0060600200, 17000700ac351c00, 37000d0077e61e00, 46000b0084920200, 190012006cf81c00, 3e000b007acf1200, 3800190078db2100, 3a001100cb142300, 3f001b004a3e1100, 3f000500dc3c1100, 04001800ce761a00, 0e001f007a491b00, 2e001e00de782300, 1200050097771b00, 46000a0077920200, 100003004c351b00, 2e000b0027792300, 13001d009ccb1a00, 4a001c0051910100, 45000e0051500300, 21001600be231d00, 2b001e003b961d00, 20001c00b3bc2100, 2e001b000b7b2300, 1d001600d33e1f00, 44001d0031140500, 12001700dc771b00, 20001000d4bb2100, 4c001c0071940100, 2a00200082dc1d00, 0e0016000d491b00, 16000d00cbdb1b00, 25000300a7d71b00, 2200010076691e00, 170020004d331c00, 3f0018006d3e1100, 250006004dd71b00, 2d001e00167d2000, 39001800a3172200, 340010006c101c00, 2d000a002c7d2000, 22000400f3791e00, 02000600fe8e1a00, 38001b0007dc2100, 0d002000d0591b00, 4f001c00d86c0100, 03001b00b9001b00, 420003008fdf0700, 15000b00510e1c00, 19001c0066f91c00, 2a001400aadc1d00, 3a0021001d152300, 1600090041dc1b00, 3f0010002c3e1100, 0a000200322a1b00, 26001a0035791c00, 31000300c8191e00, 0a000f0083331b00, 0a002100ce351b00, 250002008fd81b00, 4200180029df0700, 03000900a3001b00, 2e000a00b5782300, 25001400e8d61b00, 2f0002003d2f1e00, 29000f006aff1c00, 11000500df3a1b00, 4b001000a48a0100, 380011007ddb2100, 1500170007151c00, 4e00120035640100, 32002000476d1f00, 34000500ed0e1c00, 3b001b00a82a1c00, 2e0016003a772300, 260006000c791c00, 21000a0029261d00, 12001700e7771b00, 2b001400d9951d00, 17000b002a381c00, 3300040060ca2100, 4000160027ad0e00, 04001100bc741a00, 17000d00cd371c00, 270012005d7a1c00, 02001a00c38e1a00, 440021009e140500, 240006007d8d1c00, 2d000600a57d2000, 190018004ffa1c00, 3800140092de2100, 270008000a7c1c00, 1b000f00a6171e00, 0a00140073341b00, 30000200a7621d00, 1700120082381c00, 32001b00c8701f00, 18000400e5501c00, 38001d0011dc2100, 1b001700f4151e00, 39001800a2172200, 1a001b00263e1d00, 2e001d00587a2300, 10000b0025351b00, 35001e00b3b81b00, 2600060032791c00, 1f002000a55f1f00, 40000400edab0e00, 3200000087701f00, 0600200018001a00, 3f000900483e1100, 130005007dda1a00, 26001e0091791c00, 10001f00882e1b00, 13001e005fdc1a00, 1700100026381c00, 16001f00a0d01b00, 31000400621c1e00, 2d000c008c7c2000, 22001c00b27a1e00, 360009002b7f1d00, 33001c009ecb2100, 0e0005008a481b00, 0b000f008c8f1b00, 3a00200036152300, 290012009dfe1c00, 450011005c4f0300, 44000d003d130500, 1200090020761b00, 35001000f5b51b00, 36000c00d77e1d00, 2f00060085301e00, 2500170034d61b00, 11000200743b1b00, 01001e00458f1b00, 28000e0014f01c00, 150007000b151c00, 0f000c0039c81a00, 47000300e4430200, 36000900227f1d00, 42000a007ce00700, 0e001b004a491b00, 32000200a76e1f00, 2a001c007ade1d00, 0500120097131b00, 1200100006761b00, 4800210037600200, 0f00160091c81a00, 2700210081791c00, 13001b00bedd1a00, 3f00020096371100, 02000700b38e1a00, 2600110034791c00, 27000700477a1c00, 4a000900dd910100, 4000000094ac0e00, 0d000a007e591b00, 32001d00bc711f00, 1b0000006e181e00, 26000d008b781c00, 17000f00c1371c00, 4400150007150500, 2b0013009f961d00, 29001e00beff1c00, 22001000207a1e00, 2e0016003f772300, 12000d009b761b00, 4700070099430200, 480000000a600200, 1c000300b4851f00, 47001000da430200, 44000f0014150500, 4200070060e00700, 2f000300fc2c1e00, 33000e00b6c92100, 20001000dcbb2100, 26000e004a7b1c00, 01001e00488f1b00, 1b00100018151e00, 010017006a8f1b00, 3f001600ec3c1100, 07000d00f1101b00, 22001400627a1e00, 3e000b0048cf1200, 2f00160094301e00, 4a00040015910100, 0a000700a6351b00, 3900050014192200, 1a001100d43c1d00, 2b000900d7911d00, 02001a00d88e1a00, 170008001a381c00, 34000c00960f1c00, 0d0014009c591b00, 13000a004fde1a00, 40000a0014ac0e00, 40001300dbaa0e00, 010014007d8f1b00, 34000100d5101c00, 19000b00e2f91c00, 180007000c511c00, 22000900c37a1e00, 2f00150071301e00, 2e00180006782300, 33001b0020cb2100, 49001c00f5620200, 06001100ec011a00, 2a002000aadc1d00, 04000c00e4751a00, 24000800fc8b1c00, 3c0021007bba1600, 39000b00ba192200, 2f000500f02f1e00, 18000800dc501c00, 4900060087620200, 34000d00a6101c00, 010004003b8e1b00, 2e00000092792300, 1c00140004851f00, 11001500e23b1b00, 4a001600c2910100, 11001200cb391b00, 04001300b1761a00, 470014003f430200, 1200120029771b00, 34000800ee0f1c00, 3400200012101c00, 0500210081141b00, 3f000700763d1100, 40000a003bac0e00, 11001200f9391b00, 42000300e6df0700, 0800070029a81a00, 26002100ec791c00, 13000c0060dc1a00, 1a001600cc3e1d00, 20000900b7bb2100, 2a001c00abde1d00, 3900110018182200, 2f0000003b301e00, 400016002bad0e00, 410006000b100d00, 12000300d4761b00, 2e000b00e9782300, 29000b00d8fd1c00, 0e000c00fc4a1b00, 22000200ac7a1e00, 16001e0086dc1b00, 2d000a00327d2000, 33001e0074cb2100, 2d000e00587d2000, 1a001d00a33e1d00, 3f000e009d3e1100, 26000d0087781c00, 24001500a98c1c00, 220017001f7a1e00, 3f001c00143e1100, 3f001700b23e1100, 36001700a67d1d00, 30001f005a611d00, 4900090059630200, 3c001d00fbbb1600, 03001b00ba001b00, 40000100ebaa0e00, 11001a00983a1b00, 32000b00c26f1f00, 16000d00c8db1b00, 1d000000d63d1f00, 210008007d231d00, 44001c0039140500, 2a000100c5de1d00, 10001300e4361b00, 220006000e791e00, 04000500c9761a00, 1d000a00213e1f00, 2d001400f97c2000, 10001500e6351b00, 340016001b101c00, 4000190076ab0e00, 4000140055ac0e00, 27001a00db7a1c00, 34001b00300f1c00, 19001100bdf81c00, 2f000700f92f1e00, 21001d004d211d00, 1200130098781b00, 240014009e7a1c00, 1a002100793e1d00, 42001d0030e00700, 05000400fd131b00, 41000100dc0d0d00, 4c0005005f940100, 1800120056511c00, 3400010002111c00, 40001500feab0e00, 140002009d251b00, 45002000934f0300, 3d000700af751200, 16001100e2da1b00, 2e001d00787a2300, 3f000f00443e1100, 440006001f140500, 490005005b630200, 2900070043001d00, 37001d0022e41e00, 3600000094801d00, 190004006af91c00, 36001c00237e1d00, 3f0000005f3d1100, 190021005ef71c00, 26002100c5791c00, 17001a0008371c00, 06000b0074f71900, 1d001300d03c1f00, 0a001700e7311b00, 25001b0070d81b00, 1a001000fe3d1d00, 37000f003ee41e00, 0c00180029d81a00, 420020007de00700, 2e0004004d782300, 0f000500acc91a00, 2c001800b5d41e00, 2d001200517b2000, 0f001e00c3c91a00, 30001f008c611d00, 0f000900d7c71a00, 1f000a0059601f00, 40000f0072ab0e00, 460016007a920200, 11000b00983a1b00, 4c00200070940100, 4400030077140500, 2b00070083951d00, 0d0019005b591b00, 0c0015009fd71a00, 1c001d0063851f00, 38001f00d6dd2100, 36000b00587d1d00, 1b00200068161e00, 40000000a5ac0e00, 1c001e00b9851f00, 0d000e00ab591b00, 2d000c00867c2000, 130009007bdb1a00, 2d000b00077d2000, 3100130097191e00, 1b001700fa151e00, 12001b0081761b00, 3d001e002d751200, 26002100b6791c00, 2600040046791c00, 0e000b0008491b00, 11000500c43a1b00, 2b001e006d961d00, 4f001900206d0100, 2e000d0028782300, 2c000d00cad51e00, 310002000c1b1e00, 13000d009edc1a00, 2000040034bb2100, 1d000c00e53d1f00, 24001a001e8c1c00, 240005004e8b1c00, 270002009f7b1c00, 0a000e003f331b00, 34000a0091111c00, 200000004cba2100, 36000c00d37e1d00, 33000500c5cb2100, 3200210073711f00, 49000d0043630200, 11001f00f63b1b00, 2b0001008b951d00, 0400100041751a00, 24001000e38b1c00, 10000a00c5351b00, 310011009a1b1e00, 1f0011002b631f00, 1200140032751b00, 4900020016630200, 1b001d0027161e00, 1b001a00d7161e00, 1c002100dd841f00, 1600080024dd1b00, 13001000f4da1a00, 11001200e7391b00, 3e00180050d01200, 2900110015001d00, 47000200cc430200, 38000f0026dd2100, 14000f00c0251b00, 21001100df231d00, 390008005e182200, 0f000200d6c71a00, 36000f007d7e1d00, 24000c00f98c1c00, 4f000b00b26c0100, 040003008f771a00, 20000900c7bb2100, 4c00180041940100, 4c0005005a940100, 25001200a5d71b00, 4600190025930200, 4600150034930200, 2a000f004cdd1d00, 10000a00d8351b00, 12001c0034751b00, 27000500177b1c00, 34000c00910f1c00, 390021009e172200, 39001400be182200, 3400080016101c00, 40001c00a6ab0e00, 29000000c7fe1c00, 03001c003d001b00, 44001a00e3140500, 3700060071e41e00, 1f00160012621f00, 4a000900ea910100, 19000a006df81c00, 39000300ce182200, 13000000cbda1a00, 3000160099631d00, 48001300f65f0200, 3d000900da751200, 04001800d0761a00, 3e001c00f9d11200, 2e0015009f792300, 2c001a00d1d51e00, 2700210047791c00, 02000a00158f1a00, 38001f00a6dd2100, 2a0020007bdc1d00, 2b000a005d941d00, 0400020074761a00, 15000e0094131c00, 21001e0024251d00, 39000f0024182200, 36000400b07e1d00, 20001a00ccbb2100, 36001a00287f1d00, 0f00180071c71a00, 29001b0055ff1c00, 0500020038151b00, 1c00090024851f00, 20000e006bbd2100, 3e00170094d01200, 13000a0009de1a00, 1f00140003601f00, 2c0017008ed51e00, 1e00150074701e00, 3f0003004d3d1100, 28001a002ff11c00, 3f001300a63d1100, 3b000200712a1c00, 3b00050092291c00, 37001200d4e61e00, 42001000acdf0700, 1200040024771b00, 42001c009edf0700, 3e000600ded11200, 1e0012002d711e00, 2500170030d61b00, 0d001100365b1b00, 34001a00500f1c00, 4b001400cb890100, 46000700db920200, 1c000600c7851f00, 0b000f006d8f1b00, 25001a0012d81b00, 4f000e003b6d0100, 0d00090011591b00, 010012007a901b00, 2d001d007e7c2000, 2d0012005a7b2000, 0a000c000f301b00, 03000900a5001b00, 2e000700fe792300, 33000b0000cb2100, 36002100fe7c1d00, 400004001aac0e00, 1700090015381c00, 1b0002000d171e00, 27001600bb7b1c00, 11000e0027381b00, 16001a0036db1b00, 3a001f00ad142300, 3700100005e41e00, 380014008ede2100, 110009007c3a1b00, 34000d00ac101c00, 27001000c77b1c00, 3d000e00c4731200, 20001b00ffbb2100, 1b001b005a151e00, 3d001d00b0731200, 4e000500e7630100, 10000d007e361b00, 1a000c00e33f1d00, 3300080003ca2100, 220000005d781e00, 0e0007006e481b00, 27001d008f7a1c00, 48000f00fa5f0200, 24001300e3871c00, 1f00030063611f00, 22000e0086791e00, 40001800acac0e00, 360005000d7d1d00, 0d001400ae591b00, 210003009a231d00, 3f001b00393e1100, 0c000d00e2d61a00, 02000700a08e1a00, 1700120081381c00, 3c001500cfbb1600, 12000c0044761b00, 1f001b0072611f00, 3c001500a9bb1600, 30000100d6611d00, 0e000500ab481b00, 3e000600d4d11200, 36001900ee801d00, 3d0020003c741200, 260011003f791c00, 2000200028bc2100, 1f000900d4601f00, 03001b00b7001b00, 4f001100396d0100, 3c0012006eba1600, 1a001700c23c1d00, 17001e00f0381c00, 27001300e97b1c00, 3f000800f33d1100, 0e000f004b491b00, 1d001600d63e1f00, 31002000e1191e00, 1200050096771b00, 34001400a9101c00, 4000210002ac0e00, 0d000b00555a1b00, 30002000ce5f1d00, 11001e00533d1b00, 10000f008a351b00, 1d0008007d3e1f00, 120000007b761b00, 40001100bfac0e00, 22001900487b1e00, 2e000e00dd772300, 3e000a00aecf1200, 0d00080096591b00, 13002000a7dc1a00, 20000d00c9bc2100, 2c000b0072d51e00, 1b000e00e7151e00, 2c000e00cdd41e00, 21000e0051241d00, 26002100bb791c00, 0d00010070591b00, 1f000b00d65f1f00, 1f000800c3601f00, 20000c0090bb2100, 32000200866e1f00, 3f001e00483e1100, 37000b000ee41e00, 48000200bc5f0200, 29001600ccff1c00, 19001400e5f81c00, 1e00000023711e00, 07001800420f1b00, 3a000600e6152300, 0b001e0016901b00, 420002005ce00700, 34001f0047111c00, 1b000f00a8171e00, 3e0002008ed01200, 3d000800ce731200, 0a0019002d331b00, 34000d00d6101c00, 0d0001007e591b00, 2f000e0015301e00, 2e00010057772300, 35000b00dcb71b00, 3a00150057142300, 22001800887a1e00, 1f00070035611f00, 3b001300372b1c00, 0f000200bbc71a00, 24000c001e8d1c00, 20001f0064ba2100, 0f00210059c81a00, 2b001e003f961d00, 3300210002cb2100, 22001400067a1e00, 2b001a00db951d00, 050013003c131b00, 21001100e2231d00, 3d000f00bf731200, 13001400e1dc1a00, 0f000300e4c81a00, 1d000200673e1f00, 0600000062001a00, 11000800d73a1b00, 07001f00a70d1b00, 09001d00febd1a00, 22000a00107b1e00, 22001c00ad7a1e00, 1d001300a23c1f00, 210017000a251d00, 39001300c3162200, 4000010034ab0e00, 3a00130084142300, 2b001a00b5951d00, 0a0019003b331b00, 04001300ad761a00, 3400100081101c00, 0500020029151b00, 4b001300a28a0100, 2500170026d61b00, 0a001c0030341b00, 30001f0078611d00, 42001e00e6de0700, 13001700bcdd1a00, 24001700d18c1c00, 020013004f8e1a00, 1d0009003b3d1f00, 31001a009a1b1e00, 26000d00a9781c00, 47000d00ce430200, 11000a00363c1b00, 27001a00ef7a1c00, 32000600c6701f00, 06000c0015011a00, 4e00030043640100, 260015001f791c00, 2f000c00952e1e00, 3a000f0005142300, 11001800563c1b00, 0500210092141b00, 2500050008d91b00, 2e000a00a0782300, 1d000d00893d1f00, 19001d0048f81c00, 36001200837f1d00, 16000600b4db1b00, 47001700cf430200, 0400170098751a00, 22000200bd7a1e00, 01000700608d1b00, 0d00190074591b00, 2100180052251d00, 1e00190054701e00, 1900070043fa1c00, 15001800e6141c00, 3f0021004e3c1100, 2e00150063792300, 31001100a21b1e00, 08001c00d1a51a00, 39001b006d192200, 4000110013ad0e00, 10000800b5361b00, 2d0005006c7d2000, 40000200fbac0e00, 3d001b0014741200, 4000160060ad0e00, 1c001d0099851f00, 27000a000c7d1c00, 3a000000bf152300, 1700200074331c00, 470008000e430200, 25001b0065d81b00, 34001b00700f1c00, 1a0000000d3f1d00, 310001000a1a1e00, 4900090068630200, 22000a003d7b1e00, 1b000b002c161e00, 1b000e00e1151e00, 2a00060023de1d00, 4c00020045940100, 15000f0073131c00, 290005004ffe1c00, 40000a0003ac0e00, 1c000900f8841f00, 3f0013007c3d1100, 3800040012dd2100, 42000800ade00700, 0e00110067491b00, 35001d00f0b71b00, 29001300d3fe1c00, 22000d00137b1e00, 01000200a38f1b00, 4c001400b0930100, 1a0013001a3e1d00, 0a00130065351b00, 36001b00657e1d00, 3a001200fd142300, 0d000d003d5a1b00, 4f000b00c36c0100, 43001c0097030900, 31000800561a1e00, 12002100d8751b00, 0a00120047331b00, 2b001b0081951d00, 1500140012161c00, 31001a009e1b1e00, 3000050085611d00, 1f00030036611f00, 4e000500ce630100, 12000d0064761b00, 42000b00f5df0700, 2e000800a6762300, 1b00120062171e00, 3a00090036152300, 44000500d9140500, 1e0004003a711e00, 1a001b00103e1d00, 01002000828e1b00, 3e001300c0cf1200, 3c000f002ab91600, 25001b006cd81b00, 18000500a9511c00, 46000b0089920200, 26001d003e791c00, 40000200f1ac0e00, 0a00130080351b00, 0f00000048c91a00, 210018007f251d00, 36000100217e1d00, 05000e00b5141b00, 22000a00177b1e00, 3e001300f2cf1200, 360018003c7d1d00, 4200020065e00700, 19000b00f0f91c00, 240005004f8b1c00, 0d001c00a85a1b00, 3c00050055bb1600, 18000e006a521c00, 0c0009000bd81a00, 1600050035dc1b00, 07000f008e0f1b00, 1c00020071861f00, 3d000900ba751200, 2e000800ac762300, 3100160021181e00, 1700130055361c00, 3e001600d7d01200, 3d001e00fa741200, 49001b0017630200, 27001f00e77c1c00, 2100040047241d00, 2f00160069301e00, 1700110051381c00, 4f0008001b6d0100, 24001e00b58c1c00, 37001f0081e21e00, 11001c00fc3b1b00, 440021006f140500, 3e001f00ced11200, 24000a00cf8b1c00, 32001200f26f1f00, 2200000057781e00, 27001000c07b1c00, 2200010063691e00, 42001400eedf0700, 460014004c930200, 4c00200054940100, 0a002100fb351b00, 3e000a0086cf1200, 3e0011007bcf1200, 27000300547d1c00, 3c000a00fdba1600, 42001c0097df0700, 10001500f0351b00, 40001e00b2ab0e00, 34001100f10f1c00, 29000b00e2fd1c00, 29001600fcff1c00, 3e000000e2d11200, 22001000337a1e00, 3f000700813d1100, 13000c0050dc1a00, 1f00140024601f00, 19001e0046f81c00, 1a000b00743d1d00, 3700130080e71e00, 37000a0024e41e00, 4b001b00d1890100, 160017004adb1b00, 190021006bf71c00, 07001400880d1b00, 4a001000ed910100, 22001d007b7a1e00, 020013006e8e1a00, 3a0002001a132300, 01000e00468e1b00, 42000f00d7e00700, 47000200d0430200, 4200000013e10700, 0400010068741a00, 0f00060012c81a00, 42001b0096df0700, 4b001800778a0100, 42001d00e3df0700, 3a0002001b132300, 3c00160098ba1600, 40001b0013ad0e00, 4900020025630200, 0b0019007c861b00, 15000e009b131c00, 40001a006dac0e00, 24000500278b1c00, 34000f00540e1c00], registeredDmlCount=15664429, committedDmlCount=12388717, errorCount=1, warningCount=37, scnFreezeCount=0, unparsableDdlCount=37, miningSessionUserGlobalAreaMemory=9064720, miningSessionUserGlobalAreaMaxMemory=42802776, miningSessionProcessGlobalAreaMemory=63184808, miningSessionProcessGlobalAreaMaxMemory=63315880} (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:161)
[2021-08-20 14:16:29,542] INFO Offsets: OracleOffsetContext [scn=915503569606] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:162)
[2021-08-20 14:16:29,542] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:173)