diff --git a/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go b/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go
index 7f52cdf66d..38c0bc8140 100644
--- a/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go
+++ b/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go
@@ -225,8 +225,8 @@ func NewRocksMQ(name string, idAllocator allocator.Interface) (*rocksmq, error)
 
 	// db, err := gorocksdb.OpenDb(opts, name)
 	// use properties as the column families to store trace id
-	giveColumnFamilies := []string{"default"}
-	db, cfHandles, err := gorocksdb.OpenDbColumnFamilies(optsStore, name, giveColumnFamilies, []*gorocksdb.Options{optsStore})
+	giveColumnFamilies := []string{"default", "properties"}
+	db, cfHandles, err := gorocksdb.OpenDbColumnFamilies(optsStore, name, giveColumnFamilies, []*gorocksdb.Options{optsStore, optsStore})
 	if err != nil {
 		return nil, err
 	}