diff --git a/internal/util/rocksmq/client/rocksmq/client_impl.go b/internal/util/rocksmq/client/rocksmq/client_impl.go index 2994d72058..3e0747b8df 100644 --- a/internal/util/rocksmq/client/rocksmq/client_impl.go +++ b/internal/util/rocksmq/client/rocksmq/client_impl.go @@ -32,7 +32,7 @@ type client struct { func newClient(options ClientOptions) (*client, error) { if options.Server == nil { - return nil, newError(InvalidConfiguration, "Server is nil") + return nil, newError(InvalidConfiguration, "options.Server is nil") } if options.Ctx == nil {