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 index 81da25eabd..b66a46d413 100644 --- 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> readManifestForChannel(final String channel range.setStart(oldestSlab); consistency = ConsistencyLevel.CL_LOCAL_ONE; } else { - consistency = ConsistencyLevel.CL_LOCAL_QUORUM; + consistency = ConsistencyLevel.CL_TWO; } final Iterator> 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 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));