Fix an issue where maxlag partition is selected badly

CHANGELOG.md

@@ -1,3 +1,8 @@
+## X.Y.Z (TBD)
+
+Bugfixes:
+  - Fix an issue where maxlag partition is selected badly
+
 ## 0.1.1 (2016-05-01)
 
 Features:

offsets_store.go

@@ -510,6 +510,7 @@ func (storage *OffsetStorage) evaluateGroup(cluster string, group string, result
 			// Check if this partition is the one with the most lag currently
 			if lastOffset.Lag > maxlag {
 				status.Maxlag = thispart
+				maxlag = lastOffset.Lag
 			}
 			status.TotalLag += uint64(lastOffset.Lag)