From d60ea8bc21ffea8af7aa2450b5eaecb080f37c6c Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 10 Sep 2021 17:42:10 +0800 Subject: [PATCH] Change prefix length to FixedChannelNameLen + 1 (#7717) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 68b5587574..4536d8c534 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -113,7 +113,7 @@ func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*rocksmq, erro opts := gorocksdb.NewDefaultOptions() opts.SetBlockBasedTableFactory(bbto) opts.SetCreateIfMissing(true) - opts.SetPrefixExtractor(gorocksdb.NewFixedPrefixTransform(FixedChannelNameLen)) + opts.SetPrefixExtractor(gorocksdb.NewFixedPrefixTransform(FixedChannelNameLen + 1)) db, err := gorocksdb.OpenDb(opts, name) if err != nil {