updated to CLTWO

bazaarvoice · Mar 5, 2024 · e59d42b · e59d42b
1 parent 3a17878
commit e59d42b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java b/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java
@@ -346,7 +346,7 @@ private Iterator<Column<ByteBuffer>> readManifestForChannel(final String channel
             range.setStart(oldestSlab);
             consistency = ConsistencyLevel.CL_LOCAL_ONE;
         } else {
-            consistency = ConsistencyLevel.CL_LOCAL_QUORUM;
+            consistency = ConsistencyLevel.CL_TWO;
         }
 
         final Iterator<Column<ByteBuffer>> manifestColumns = executePaginated(
@@ -399,7 +399,7 @@ private boolean readSlab(String channel, ByteBuffer slabId, SlabCursor cursor, b
         // Using a lower consistency level could result in (a) duplicate events because we miss deletes and (b)
         // incorrectly closing or deleting slabs when slabs look empty if we miss adds.
         ColumnList<Integer> eventColumns = execute(
-                _keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_LOCAL_QUORUM)
+                _keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_TWO)
                         .getKey(slabId)
                         .withColumnRange(start, Constants.OPEN_SLAB_MARKER, false, Integer.MAX_VALUE));