From 18e0581d5cb78a97e91eb233a581bd6cacce88fe Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 31 Mar 2021 14:10:07 +0800 Subject: [PATCH] Destroy readOptions after use Signed-off-by: yukun --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index c1a564bf5c..15aaf5ed03 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -295,6 +295,7 @@ func (rmq *rocksmq) Consume(topicName string, groupName string, n int) ([]Consum } readOpts := gorocksdb.NewDefaultReadOptions() + defer readOpts.Destroy() readOpts.SetPrefixSameAsStart(true) iter := rmq.store.NewIterator(readOpts) defer iter.Close()