diff --git a/balancer.go b/balancer.go index ca5da6b3d..816d091d1 100644 --- 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 }