2025-08-26T08:33:41.3069584Z 2025-08-26 08:33:41,281 ERROR  EmbeddedEngineTest||engine  Engine has failed with    [io.debezium.embedded.async.AsyncEmbeddedEngine]
2025-08-26T08:33:41.3072861Z java.util.concurrent.ExecutionException: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@60cd912b[Not completed, task = io.debezium.embedded.async.ProcessingCallables$TransformAndConvertRecord@547d4758] rejected from java.util.concurrent.ThreadPoolExecutor@5b619d14[Shutting down, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]
2025-08-26T08:33:41.3076076Z 	at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
2025-08-26T08:33:41.3076960Z 	at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191)
2025-08-26T08:33:41.3078024Z 	at io.debezium.embedded.async.AsyncEmbeddedEngine.runTasksPolling(AsyncEmbeddedEngine.java:511)
2025-08-26T08:33:41.3079200Z 	at io.debezium.embedded.async.AsyncEmbeddedEngine.run(AsyncEmbeddedEngine.java:221)
2025-08-26T08:33:41.3080537Z 	at io.debezium.embedded.EmbeddedEngineTest.lambda$shouldHandleNoDefaultOffsetFlushInterval$31(EmbeddedEngineTest.java:878)
2025-08-26T08:33:41.3081918Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
2025-08-26T08:33:41.3083051Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
2025-08-26T08:33:41.3083924Z 	at java.base/java.lang.Thread.run(Thread.java:1583)
2025-08-26T08:33:41.3092963Z Caused by: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@60cd912b[Not completed, task = io.debezium.embedded.async.ProcessingCallables$TransformAndConvertRecord@547d4758] rejected from java.util.concurrent.ThreadPoolExecutor@5b619d14[Shutting down, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]
2025-08-26T08:33:41.3096395Z 	at java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2081)
2025-08-26T08:33:41.3097687Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:841)
2025-08-26T08:33:41.3098830Z 	at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1376)
2025-08-26T08:33:41.3100041Z 	at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:145)
2025-08-26T08:33:41.3101850Z 	at io.debezium.embedded.async.ParallelSmtAndConvertBatchProcessor.lambda$processRecords$0(ParallelSmtAndConvertBatchProcessor.java:44)
2025-08-26T08:33:41.3103419Z 	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
2025-08-26T08:33:41.3104750Z 	at java.base/java.util.stream.ReferencePipeline$Head.forEachOrdered(ReferencePipeline.java:772)
2025-08-26T08:33:41.3106273Z 	at io.debezium.embedded.async.ParallelSmtAndConvertBatchProcessor.processRecords(ParallelSmtAndConvertBatchProcessor.java:44)
2025-08-26T08:33:41.3107862Z 	at io.debezium.embedded.async.AsyncEmbeddedEngine$PollRecords.doCall(AsyncEmbeddedEngine.java:1222)
2025-08-26T08:33:41.3109130Z 	at io.debezium.embedded.async.AsyncEmbeddedEngine$PollRecords.doCall(AsyncEmbeddedEngine.java:1202)
2025-08-26T08:33:41.3110257Z 	at io.debezium.embedded.async.RetryingCallable.call(RetryingCallable.java:47)
2025-08-26T08:33:41.3111129Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
2025-08-26T08:33:41.3112136Z 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
2025-08-26T08:33:41.3113074Z 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
2025-08-26T08:33:41.3113737Z 	... 3 common frames omitted