Method Balance

balancer.go:25–25

Balance receives a message and a set of available partitions and returns the partition number that the message should be routed to. An application should refrain from using a balancer to manage multiple sets of partitions (from different topics for examples), use one balancer instance for each part

(msg Message, partitions ...int)

	// instance for each partition set, so the balancer can detect when the
	// partitions change and assume that the kafka topic has been rebalanced.
	Balance(msg Message, partitions ...int) (partition int)
}

// BalancerFunc is an implementation of the Balancer interface that makes it