From 969c78e79d540f2473abe3069a3814d4c35366aa Mon Sep 17 00:00:00 2001 From: yukun Date: Sat, 9 Oct 2021 00:11:36 +0800 Subject: [PATCH] [skip ci]Add comments for rocksmq close (#9519) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 5cf2211f8c..f1137972a8 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -166,6 +166,10 @@ func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*rocksmq, erro return rmq, nil } +// Close step: +// 1. Stop retention +// 2. Destroy all consumer groups and topics +// 3. Close rocksdb instance func (rmq *rocksmq) Close() { rmq.stopRetention() rmq.storeMu.Lock()