add LeastBytes balancer (be explicit about no risks of overflow)

huangfu · Jun 20, 2017 · ea25e09 · ea25e09
1 parent 27321f0
commit ea25e09
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/balancer.go b/balancer.go
@@ -77,7 +77,7 @@ func (lb *LeastBytes) Balance(msg Message, partitions ...int) int {
 	}
 
 	c := &lb.counters[minIndex]
-	c.bytes += uint64(len(msg.Key) + len(msg.Value))
+	c.bytes += uint64(len(msg.Key)) + uint64(len(msg.Value))
 	return c.partition
 }