The default option for processing threads in async engine is Executors.newCachedThreadPool() which is unbounded (the upper bound is Integer.MAX_VALUE), resulting into creating too many threads for bigger batches and slow down due to context switching and memory overhead when processing the batch.