reds_reverting_changes (#817)

Author: mukeshsbbv

event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java

@@ -340,19 +340,13 @@ public void readNewer(String channel, EventSink sink) {
      */
     private Iterator<Column<ByteBuffer>> readManifestForChannel(final String channel, final boolean weak) {
         final ByteBuffer oldestSlab = weak ? _oldestSlab.getIfPresent(channel) : null;
-        ConsistencyLevel consistency = ConsistencyLevel.CL_LOCAL_ONE ;//CL_LOCAL_QUORUM;;
-
+        final ConsistencyLevel consistency;
         RangeBuilder range = new RangeBuilder().setLimit(50);
         if (oldestSlab != null) {
             range.setStart(oldestSlab);
+            consistency = ConsistencyLevel.CL_LOCAL_ONE;
         } else {
-
-            try{
-                String _sysConsistency = System.getProperty("read-consistency");
-                consistency = ConsistencyLevel.valueOf(_sysConsistency);
-            } catch(Exception e){
-                _log.debug("encountered exception while parsing ", e);
-            }
+            consistency = ConsistencyLevel.CL_LOCAL_QUORUM;
         }
 
         final Iterator<Column<ByteBuffer>> manifestColumns = executePaginated(
@@ -405,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_ONE)
+                _keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_LOCAL_QUORUM)
                         .getKey(slabId)
                         .withColumnRange(start, Constants.OPEN_SLAB_MARKER, false, Integer.MAX_VALUE));