@@ -800,6 +800,7 @@ public ApiFuture<Empty> asyncClose() {
 public void close() {
 synchronized (lock) {
 numSessionsInUse--;
+numSessionsReleased++;
 }
 Exception = null;
 if (lastException != null && isSessionNotFound(lastException)) {
@@ -1462,6 +1463,7 @@ private PooledSession replaceSession(
 if (!options.isFailIfSessionNotFound() && session.allowReplacing) {
 synchronized (lock) {
 numSessionsInUse--;
+numSessionsReleased++;
 }
 session.Exception = null;
 invalidateSession(session);
@@ -1482,6 +1484,7 @@ private void incrementNumSessionsInUse() {
 if (maxSessionsInUse < ++numSessionsInUse) {
 maxSessionsInUse = numSessionsInUse;
 }
+numSessionsAcquired++;
 }
 }
 
@@ -1523,7 +1526,6 @@ private void releaseSession(PooledSession session, Position position) {
 if (closureFuture != null) {
 return;
 }
-numSessionsReleased++;
 if (readWaiters.size() == 0 && numSessionsBeingPrepared >= readWriteWaiters.size()) {
 // No pending waiters
 if (shouldPrepareSession()) {

@@ -1589,6 +1589,10 @@ public void testSessionMetrics() throws Exception {
 assertThat(record.getMetrics()).containsEntry(MetricRegistryConstants.IN_USE_SESSIONS, 2L);
 assertThat(record.getMetrics()).containsEntry(MetricRegistryConstants.MAX_IN_USE_SESSIONS, 2L);
 assertThat(record.getMetrics()).containsEntry(MetricRegistryConstants.GET_SESSION_TIMEOUTS, 0L);
+assertThat(record.getMetrics())
+.containsEntry(MetricRegistryConstants.NUM_ACQUIRED_SESSIONS, 2L);
+assertThat(record.getMetrics())
+.containsEntry(MetricRegistryConstants.NUM_RELEASED_SESSIONS, 0L);
 assertThat(record.getMetrics())
 .containsEntry(
 MetricRegistryConstants.MAX_ALLOWED_SESSIONS, (long) options.getMaxSessions());
@@ -1626,9 +1630,9 @@ public Void call() {
 assertThat(record.getMetrics().get(MetricRegistryConstants.GET_SESSION_TIMEOUTS).longValue())
 .isAtLeast(1L);
 assertThat(record.getMetrics())
-.containsEntry(MetricRegistryConstants.NUM_ACQUIRED_SESSIONS, 0L);
+.containsEntry(MetricRegistryConstants.NUM_ACQUIRED_SESSIONS, 3L);
 assertThat(record.getMetrics())
-.containsEntry(MetricRegistryConstants.NUM_RELEASED_SESSIONS, 5L);
+.containsEntry(MetricRegistryConstants.NUM_RELEASED_SESSIONS, 3L);
 assertThat(record.getMetrics()).containsEntry(MetricRegistryConstants.IN_USE_SESSIONS, 0L);
 assertThat(record.getMetrics()).containsEntry(MetricRegistryConstants.MAX_IN_USE_SESSIONS, 2L);
 }