diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
index e2529d3e5e..5cf6621b63 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@@ -62,7 +62,7 @@ const (
 	CurrentIDSuffix  = "current_id"
 	ReaderNamePrefix = "reader-"
 
-	RmqNotServingErrMsg = "Rocksmq is not serving"
+	RmqNotServingErrMsg = "rocksmq is not serving"
 )
 
 const (
@@ -992,7 +992,7 @@ func (rmq *rocksmq) CreateReader(topicName string, startMsgID UniqueID, messageI
 	}
 	nowTs, err := getNowTs(rmq.idAllocator)
 	if err != nil {
-		return "", errors.New("Can't get current ts from rocksmq idAllocator")
+		return "", errors.New("can't get current ts from rocksmq idAllocator")
 	}
 	readerName := subscriptionRolePrefix + ReaderNamePrefix + strconv.FormatInt(nowTs, 10)