!163 merge

Merge pull request !163 from AE86/design_consumer

dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/StorageBufferActuator.java

@@ -50,7 +50,7 @@ public final class StorageBufferActuator extends AbstractBufferActuator<StorageR
 
     @Override
     protected void pull(StorageResponse response) {
-        storageExecutor.execute(() -> storageService.addBatch(StorageEnum.DATA, response.getMetaId(), response.getDataList()));
+        storageService.addBatch(StorageEnum.DATA, response.getMetaId(), response.getDataList());
     }
 
     @Override