From e3ce1696e77206cbe28d4143d8393608ddea04dd Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 12 Oct 2021 19:37:20 +0800 Subject: [PATCH] [skip ci]Add comments for rocksmq DestroyTopic (#9735) Signed-off-by: fishpenguin --- 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 875136f561..86f6db15e2 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -283,6 +283,7 @@ func (rmq *rocksmq) CreateTopic(topicName string) error { return nil } +// DestroyTopic removes messages for topic in rocksdb func (rmq *rocksmq) DestroyTopic(topicName string) error { start := time.Now() beginKey := topicName + "/begin_id"