From 29d789edcaa3408e569e96e76bd71591ee66dbe7 Mon Sep 17 00:00:00 2001
From: Robin Han <hanxvdovehx@gmail.com>
Date: Mon, 30 Aug 2021 11:36:28 +0800
Subject: [PATCH] (fix): set subversion when #Subscribe (#720)

---
 consumer/consumer.go | 1 +
 1 file changed, 1 insertion(+)

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