fix Subscribe bug (#346)

Co-authored-by: guyinyou <[email protected]>
apache · Jan 17, 2023 · 83493ea · 83493ea
1 parent aa3e9fd
commit 83493ea
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/golang/simple_consumer.go b/golang/simple_consumer.go
@@ -340,6 +340,9 @@ var NewSimpleConsumer = func(config *Config, opts ...SimpleConsumerOption) (Simp
 		awaitDuration:           scOpts.awaitDuration,
 		subscriptionExpressions: scOpts.subscriptionExpressions,
 	}
+	if sc.subscriptionExpressions == nil {
+		sc.subscriptionExpressions = make(map[string]*FilterExpression)
+	}
 	sc.cli.initTopics = make([]string, 0)
 	for topic, _ := range scOpts.subscriptionExpressions {
 		sc.cli.initTopics = append(sc.cli.initTopics, topic)