fix test

8 months ago · b166597c83
2 changed files with 0 additions and 3 deletions
--- a/weed/mq/pub_balancer/allocate_test.go
+++ b/weed/mq/pub_balancer/allocate_test.go
@ -12,7 +12,6 @@ func Test_allocateOneBroker(t *testing.T) {
 	brokers := cmap.New[*BrokerStats]()
 	brokers.SetIfAbsent("localhost:17777", &BrokerStats{
 		TopicPartitionCount: 0,
-		ConsumerCount:       0,
 		CpuUsagePercent:     0,
 	})

--- a/weed/mq/pub_balancer/balance_brokers_test.go
+++ b/weed/mq/pub_balancer/balance_brokers_test.go
@ -12,7 +12,6 @@ func TestBalanceTopicPartitionOnBrokers(t *testing.T) {
 	brokers := cmap.New[*BrokerStats]()
 	broker1Stats := &BrokerStats{
 		TopicPartitionCount: 1,
-		ConsumerCount:       1,
 		CpuUsagePercent:     1,
 		TopicPartitionStats: cmap.New[*TopicPartitionStats](),
 	}
@ -24,7 +23,6 @@ func TestBalanceTopicPartitionOnBrokers(t *testing.T) {
 	})
 	broker2Stats := &BrokerStats{
 		TopicPartitionCount: 2,
-		ConsumerCount:       1,
 		CpuUsagePercent:     1,
 		TopicPartitionStats: cmap.New[*TopicPartitionStats](),
 	}