[ISSUE #688] fix: type assert panic

apache · Jul 5, 2021 · 2bdc662 · 2bdc662
1 parent 76dd050
commit 2bdc662
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
@@ -144,7 +144,7 @@ func (c *defaultPullConsumer) getNextQueueOf(topic string) *primitive.MessageQue
 	v, exist := queueCounterTable.Load(topic)
 	if !exist {
 		index = -1
-		queueCounterTable.Store(topic, 0)
+		queueCounterTable.Store(topic, int64(0))
 	} else {
 		index = v.(int64)
 	}