Function Test_stickyBalanceStrategy_Plan_data_race

balance_strategy_test.go:2090–2105

(t *testing.T)

}

func Test_stickyBalanceStrategy_Plan_data_race(t *testing.T) {
	for range 1000 {
		go func(bs BalanceStrategy) {
			members := map[string]ConsumerGroupMemberMetadata{
				"m1": {
					Version: 3,
					Topics:  []string{"topic"},
				},
			}
			topics := map[string][]int32{
				"topic": {0, 1, 2},
			}
			_, _ = bs.Plan(members, topics)
		}(NewBalanceStrategySticky())
	}
}

func BenchmarkStickAssignmentWithLargeNumberOfConsumersAndTopics(b *testing.B) {
	s := &stickyBalanceStrategy{}