| commit | 2bdc662c91c92aa0f68a90f1db5a3c4b6e677db0 | [log] [tgz] |
|---|---|---|
| author | Berlin <fengberlin@qq.com> | Mon Jul 05 10:58:29 2021 +0800 |
| committer | GitHub <noreply@github.com> | Mon Jul 05 10:58:29 2021 +0800 |
| tree | ec150bca715bdd16df66d947411eb947fedf28c8 | |
| parent | 76dd050fbbd06d59c5fb3e8fe5ab187521167436 [diff] |
[ISSUE #688] fix: type assert panic
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go index 3a54194..0b0ef56 100644 --- a/consumer/pull_consumer.go +++ b/consumer/pull_consumer.go
@@ -144,7 +144,7 @@ v, exist := queueCounterTable.Load(topic) if !exist { index = -1 - queueCounterTable.Store(topic, 0) + queueCounterTable.Store(topic, int64(0)) } else { index = v.(int64) }