(fix): set subversion when #Subscribe (#720)

apache · Aug 30, 2021 · 29d789e · 29d789e
1 parent 0922226
commit 29d789e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -993,6 +993,7 @@ func buildSubscriptionData(topic string, selector MessageSelector) *internal.Sub
 		SubString: selector.Expression,
 		ExpType:   string(selector.Type),
 	}
+	subData.SubVersion = time.Now().UnixNano()
 
 	if selector.Type != "" && selector.Type != TAG {
 		return subData