[2022-05-12 08:37:05,962] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Finished commitOffsets successfully in 12984 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:574) [2022-05-12 08:37:12,088] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:37:12,088] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 14 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:37:36,627] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Finished commitOffsets successfully in 24539 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:574) [2022-05-12 08:37:42,469] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:37:42,469] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:37:48,358] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:37:48,358] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:37:54,179] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:37:54,179] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:38:00,073] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:38:00,073] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:38:12,126] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:38:12,126] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:38:24,098] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:38:24,098] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:38:36,158] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:38:41,984] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:38:53,833] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:38:59,570] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:39:11,451] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:39:29,364] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:39:29,364] INFO [Worker clientId=connect-1, groupId=debezium-connect-cluster-second] Member connect-1-32df909c-ec7e-4773-a0ee-7b88360dd960 sending LeaveGroup request to coordinator kp-kafkacinsaint135-564-aint5.wbx2.com:9093 (id: 2147483083 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1005) [2022-05-12 08:39:35,247] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:39:35,247] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:39:35,247] ERROR [Worker clientId=connect-1, groupId=debezium-connect-cluster-second] Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:302) java.lang.OutOfMemoryError: Java heap space at java.util.stream.Nodes.builder(Nodes.java:167) at java.util.stream.ReferencePipeline.makeNodeBuilder(ReferencePipeline.java:131) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:544) at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:505) at org.apache.kafka.common.requests.MetadataResponse.convertToNodeArray(MetadataResponse.java:165) at org.apache.kafka.common.requests.MetadataResponse.toPartitionInfo(MetadataResponse.java:156) at org.apache.kafka.clients.MetadataCache.lambda$computeClusterView$1(MetadataCache.java:177) at org.apache.kafka.clients.MetadataCache$$Lambda$401/931778435.apply(Unknown Source) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1628) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566) at org.apache.kafka.clients.MetadataCache.computeClusterView(MetadataCache.java:178) at org.apache.kafka.clients.MetadataCache.(MetadataCache.java:86) at org.apache.kafka.clients.MetadataCache.(MetadataCache.java:62) at org.apache.kafka.clients.Metadata.handleMetadataResponse(Metadata.java:361) at org.apache.kafka.clients.Metadata.update(Metadata.java:270) at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleSuccessfulResponse(NetworkClient.java:1081) at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:847) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:553) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227) at org.apache.kafka.connect.runtime.distributed.WorkerCoordinator.poll(WorkerCoordinator.java:161) at org.apache.kafka.connect.runtime.distributed.WorkerGroupMember.poll(WorkerGroupMember.java:179) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:432) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:294) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [2022-05-12 08:39:35,252] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67) [2022-05-12 08:39:35,256] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:327) [2022-05-12 08:39:41,135] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:39:41,135] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:39:47,768] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:39:47,768] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:39:47,768] INFO Stopped https_10443@277b8fa4{SSL,[ssl, http/1.1]}{0.0.0.0:10443} (org.eclipse.jetty.server.AbstractConnector:380) [2022-05-12 08:39:47,768] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:158) [2022-05-12 08:39:53,684] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:344) [2022-05-12 08:39:53,685] INFO [Worker clientId=connect-1, groupId=debezium-connect-cluster-second] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:676) [2022-05-12 08:39:53,684] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:39:53,685] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-05-12 08:40:00,290] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-05-12 08:40:00,290] INFO [Worker clientId=connect-1, groupId=debezium-connect-cluster-second] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:696) [2022-05-12 08:40:00,291] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72) [2022-05-12 08:40:00,291] INFO WorkerSourceTask{id=debezium-BTS-sjc-0120-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495)