for (int i = 0; i < limit; i++) {
                KeyValue kv = keyValues.get(i);
                Tuple t = Tuple.fromBytes(kv.getValue());
                completableFutures.add(readEvent(t.getString(0), t.getLong(1)));
            }