empty subcribed topic is allowed to start (apache#969)

NeonToo · 筱瑜 · web-flow · commit af75f77227b0 · 2023-04-28T10:31:20.000+08:00
Co-authored-by: 筱瑜 &lt;maoyu.dmy@alibaba-inc.com&gt;
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -540,7 +540,9 @@ func (pc *pushConsumer) validate() error {
 	}
 
 	if len(pc.subscribedTopic) == 0 {
-		return errors.New("number of subscribed topics is 0.")
+		rlog.Warning("not subscribe any topic yet", map[string]interface{}{
+			rlog.LogKeyConsumerGroup: pc.consumerGroup,
+		})
 	}
 
 	if pc.option.ConsumeConcurrentlyMaxSpan < 1 || pc.option.ConsumeConcurrentlyMaxSpan > 65535 {

Original file line number	Diff line number	Diff line change
`@@ -540,7 +540,9 @@ func (pc *pushConsumer) validate() error {`
`540`	`540`	`}`
`541`	`541`
`542`	`542`	`if len(pc.subscribedTopic) == 0 {`
`543`		`- return errors.New("number of subscribed topics is 0.")`
	`543`	`+ rlog.Warning("not subscribe any topic yet", map[string]interface{}{`
	`544`	`+ rlog.LogKeyConsumerGroup: pc.consumerGroup,`
	`545`	`+ })`
`544`	`546`	`}`
`545`	`547`
`546`	`548`	`if pc.option.ConsumeConcurrentlyMaxSpan < 1 \|\| pc.option.ConsumeConcurrentlyMaxSpan > 65535 {`