change ConsumeGoroutineNums max value allowed (#1049)

ConsumeGoroutineNums should allow large values to be set, detail see #883 (comment)
apache · May 9, 2023 · 8c4e388 · 8c4e388
1 parent 1d86ea6
commit 8c4e388
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -614,11 +614,11 @@ func (pc *pushConsumer) validate() error {
 		}
 	}
 
-	if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums > 1000 {
+	if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums > 100000 {
 		if pc.option.ConsumeGoroutineNums == 0 {
 			pc.option.ConsumeGoroutineNums = 20
 		} else {
-			return errors.New("option.ConsumeGoroutineNums out of range [1, 1000]")
+			return errors.New("option.ConsumeGoroutineNums out of range [1, 100000]")
 		}
 	}
 	return nil