diff --git a/modules/ingestor/src/main/scala/ingestor.forum.scala b/modules/ingestor/src/main/scala/ingestor.forum.scala
index 9c44856b..afbdad84 100644
--- a/modules/ingestor/src/main/scala/ingestor.forum.scala
+++ b/modules/ingestor/src/main/scala/ingestor.forum.scala
@@ -22,10 +22,12 @@ object ForumIngestor:
 
   private val topicProjection = Projection.include(List("_id", "name"))
 
-  private val interestedOperations = List(DELETE, INSERT, UPDATE, REPLACE).map(_.getValue)
+  private val interestedOperations = List(DELETE, INSERT, REPLACE).map(_.getValue)
   private val eventFilter          = Filter.in("operationType", interestedOperations)
+
   private val eventProjection = Projection.include(
     List(
+      "operationType",
       "clusterTime",
       "documentKey._id",
       "fullDocument.text",