diff --git a/consumer/consumer.go b/consumer/consumer.go
index 42bc973a..9dfc62fc 100644
--- 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