diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 66a1620c74..6545f3a78e 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -37,7 +37,7 @@ import ( // UniqueID is the type of message ID type UniqueID = typeutil.UniqueID -// Rocksmq state +// RmqState Rocksmq state type RmqState = int64 // RocksmqPageSize is the size of a message page, default 2GB