diff --git a/CHANGELOG.md b/CHANGELOG.md
index 39eec872e..48d40658c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,8 @@
 All notable changes to this project will be documented in this file. This project adheres to Semantic Versioning.
 
+### 5.2.5
+* Fix product update consumer running out of memory issue 
+
 ### 5.2.4
 * Fix order tagging rendering in case variation tags were missing
 
diff --git a/Model/Service/Sync/AbstractBulkConsumer.php b/Model/Service/Sync/AbstractBulkConsumer.php
index 58f0ed8a9..2966ad288 100644
--- a/Model/Service/Sync/AbstractBulkConsumer.php
+++ b/Model/Service/Sync/AbstractBulkConsumer.php
@@ -99,7 +99,6 @@ public function processOperation($operation)
             $message = __('Success.');
             $operation->setStatus(OperationInterface::STATUS_TYPE_COMPLETE)
                 ->setResultMessage($message);
-            $this->entityManager->save($operation);
         } catch (Exception $e) {
             $this->logger->critical(sprintf('Bulk uuid: %s. %s', $operation->getBulkUuid(), $e->getMessage()));
             /** @phan-suppress-next-line PhanTypeMismatchArgument */
@@ -107,6 +106,7 @@ public function processOperation($operation)
             $operation->setStatus(OperationInterface::STATUS_TYPE_NOT_RETRIABLY_FAILED)
                 ->setErrorCode($e->getCode())
                 ->setResultMessage($message);
+        } finally {
             $this->entityManager->save($operation);
         }
     }
diff --git a/composer.json b/composer.json
index 27652109b..415f2e97a 100644
--- a/composer.json
+++ b/composer.json
@@ -2,7 +2,7 @@
   "name": "nosto/module-nostotagging",
   "description": "Increase your conversion rate and average order value by delivering your customers personalized product recommendations throughout their shopping journey.",
   "type": "magento2-module",
-  "version": "5.2.4",
+  "version": "5.2.5",
   "require-dev": {
     "phpmd/phpmd": "^2.5",
     "sebastian/phpcpd": "*",
diff --git a/etc/module.xml b/etc/module.xml
index d9422c582..5d2511bf7 100755
--- a/etc/module.xml
+++ b/etc/module.xml
@@ -37,5 +37,5 @@
 <!--suppress XmlUnboundNsPrefix -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">
-    <module name="Nosto_Tagging" setup_version="5.2.4"/>
+    <module name="Nosto_Tagging" setup_version="5.2.5"/>
 </config>
diff --git a/etc/queue_consumer.xml b/etc/queue_consumer.xml
index effe0a961..d6c596e3c 100644
--- a/etc/queue_consumer.xml
+++ b/etc/queue_consumer.xml
@@ -38,13 +38,13 @@
     <consumer name="nosto_product_sync.update"
               queue="nosto_product_sync.update"
               connection="db"
-              maxMessages="5000"
+              maxMessages="20"
               consumerInstance="Magento\Framework\MessageQueue\Consumer"
               handler="Nosto\Tagging\Model\Service\Sync\Upsert\AsyncBulkConsumer::processOperation"/>
     <consumer name="nosto_product_sync.delete"
               queue="nosto_product_sync.delete"
               connection="db"
-              maxMessages="5000"
+              maxMessages="100"
               consumerInstance="Magento\Framework\MessageQueue\Consumer"
               handler="Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkConsumer::processOperation"/>
 </config>