Explorar o código

Change type of unvisitedPartitions from []string to bool to economize

Scott Kidder %!s(int64=6) %!d(string=hai) anos
pai
achega
b29086bdaa
Modificáronse 1 ficheiros con 2 adicións e 2 borrados
  1. 2 2
      balance_strategy.go

+ 2 - 2
balance_strategy.go

@@ -215,9 +215,9 @@ func (s *stickyBalanceStrategy) Plan(members map[string]ConsumerGroupMemberMetad
 
 	// create a mapping of each partition to its current consumer, where possible
 	currentPartitionConsumers := make(map[topicPartitionAssignment]string, len(currentAssignment))
-	unvisitedPartitions := make(map[topicPartitionAssignment][]string, len(partition2AllPotentialConsumers))
+	unvisitedPartitions := make(map[topicPartitionAssignment]bool, len(partition2AllPotentialConsumers))
 	for partition := range partition2AllPotentialConsumers {
-		unvisitedPartitions[partition] = []string{}
+		unvisitedPartitions[partition] = true
 	}
 	var unassignedPartitions []topicPartitionAssignment
 	for memberID, partitions := range currentAssignment {