diff --git a/lms/djangoapps/discussion/tasks.py b/lms/djangoapps/discussion/tasks.py
index 6e0a6b864a3c7d5d76542a7fdf8d33bace7ff0af..58a149d399471119da24d80cbbdde049dc8dc146 100644
--- a/lms/djangoapps/discussion/tasks.py
+++ b/lms/djangoapps/discussion/tasks.py
@@ -57,7 +57,9 @@ def update_discussions_map(context):
 
 
 class ResponseNotification(BaseMessageType):
-    pass
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        self.options['transactional'] = True
 
 
 @shared_task(base=LoggedTask)