empty subcribed topic is allowed to start

apache · Dec 9, 2022 · 28c9461 · 28c9461
1 parent 0742aac
commit 28c9461
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -538,7 +538,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 {