empty subcribed topic is allowed to start (#969)

Co-authored-by: 筱瑜 <[email protected]>
apache · Apr 28, 2023 · af75f77 · af75f77
1 parent ded5335
commit af75f77
Showing 1 changed file with 3 additions and 1 deletion.
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 {