go - 未知服务 Centrifugo

Question

        Channel: "public:chat",
        Data:    []byte(fmt.Sprintf(`{"input": "%s"}`, json.Get("msg").Str)),
    }
    publish, err := ctl.centRpc.Publish(context.Background(), &in)
    if err != nil {
        log.Log.Error("rpc cent error", zap.Error(err))
        fail(ctx, nil)
        return
    }
    if publish.Error != nil {
        fail(ctx, errors.New(publish.Error.Message))
        return
    }
    ok(ctx)

“rpc 错误：代码 = 未实现的 desc = 未知服务 Centrifugo”