diff --git a/x-pack/plugins/rule_registry/server/rule_data_client/rule_data_client.ts b/x-pack/plugins/rule_registry/server/rule_data_client/rule_data_client.ts
index d7ec6ea41ac8f..8ffe4e4db753f 100644
--- a/x-pack/plugins/rule_registry/server/rule_data_client/rule_data_client.ts
+++ b/x-pack/plugins/rule_registry/server/rule_data_client/rule_data_client.ts
@@ -192,7 +192,7 @@ export class RuleDataClient implements IRuleDataClient {
             return clusterClient.bulk(requestWithDefaultParameters).then((response) => {
               if (response.body.errors) {
                 const error = new errors.ResponseError(response);
-                throw error;
+                this.options.logger.error(error);
               }
               return response;
             });
diff --git a/x-pack/plugins/rule_registry/server/utils/create_persistence_rule_type_wrapper.ts b/x-pack/plugins/rule_registry/server/utils/create_persistence_rule_type_wrapper.ts
index de1193771dd95..2d914e5e0945e 100644
--- a/x-pack/plugins/rule_registry/server/utils/create_persistence_rule_type_wrapper.ts
+++ b/x-pack/plugins/rule_registry/server/utils/create_persistence_rule_type_wrapper.ts
@@ -106,14 +106,16 @@ export const createPersistenceRuleTypeWrapper: CreatePersistenceRuleTypeWrapper
                 }
 
                 return {
-                  createdAlerts: augmentedAlerts.map((alert, idx) => {
-                    const responseItem = response.body.items[idx].create;
-                    return {
-                      _id: responseItem?._id ?? '',
-                      _index: responseItem?._index ?? '',
-                      ...alert._source,
-                    };
-                  }),
+                  createdAlerts: augmentedAlerts
+                    .map((alert, idx) => {
+                      const responseItem = response.body.items[idx].create;
+                      return {
+                        _id: responseItem?._id ?? '',
+                        _index: responseItem?._index ?? '',
+                        ...alert._source,
+                      };
+                    })
+                    .filter((_, idx) => response.body.items[idx].create?.status === 201),
                 };
               } else {
                 logger.debug('Writing is disabled.');