我开发了一个小程序来与 Zeebe 交互。我使用 golang 版本 1.16 和这个库 github.com/zeebe-io/zeebe/clients/go 来访问经纪人。
我引导 Zeebe 客户端,然后使用以下代码创建已部署的建模流程的流程实例:
BrokerAddr := os.Getenv("ZEEBE_BROKER_ADDRESS")
zbClient, err := zbc.NewClient(&zbc.ClientConfig{
GatewayAddress: BrokerAddr,
UsePlaintextConnection: true,
KeepAlive: 1 * time.Second,
})
if err != nil {
panic(err)
}
request, err :=zbClient.NewCreateInstanceCommand().BPMNProcessId(triggerDataConfig.ProcessID).LatestVersion().VariablesFromObject(variables)
if err != nil {
panic(err)
}else
{
result, err := zeebeRequest.Send(context.Background())
}
然后我切换到新的客户端库 1.0.1,也移动到另一个 repo github.com/camunda-cloud/zeebe/clients/go,现在当我尝试发送请求zeebeRequest.Send(context.背景())
rpc error: code = Unimplemented desc = Method not found: gateway_protocol.Gateway/CreateProcessInstance
更新
由于downvote,我详细说明了这个问题,正确答案如下。只需将代理也更新到 1.0.1 版本