fix non-dlq backlog

uber-archive · Aug 18, 2017 · 4b6b9b5 · 4b6b9b5
1 parent 6c639d2
commit 4b6b9b5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/services/controllerhost/queueDepth.go b/services/controllerhost/queueDepth.go
@@ -345,8 +345,9 @@ func (qdc *queueDepthCalculator) computeBacklog(cgDesc *shared.ConsumerGroupDesc
 			backlog = storeMetadata.lastSequence - storeMetadata.beginSequence + 1
 		}
 	} else {
-		// update backlog, only if there is an available seqnum
-		if storeMetadata.availableSequence != math.MaxInt64 {
+		// update backlog, only if there is an available seqnum. see comment above for interpretation
+		// of "0" and "MaxInt64".
+		if storeMetadata.availableSequence != 0 && storeMetadata.availableSequence != math.MaxInt64 {
 			backlog = storeMetadata.availableSequence - cgExtent.GetAckLevelSeqNo()
 		}
 	}