检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 事务消息生产者需要实现两个回调函
tance_id}/users 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 access_key
使用TCP协议,访问业务节点的端口。 方法一:通过mqadmin命令导出源实例的元数据,然后在华为云上RocketMQ实例中创建迁移任务 获取其他厂商、自建RocketMQ或华为云上另一个RocketMQ实例的元数据 登录已准备的Linux系统主机,下载RocketMQ软件包。 wget
} time.Sleep(time.Second * 1) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 Topic:输入Topic名称。 Endpoint:输入grpc连接地址/grpc公网连接地址。 AccessKey:创建实例时,如果开启了ACL,需要输入用户名。
</dependency> 发送定时消息 发送定时消息的示例代码如下,或者通过ProducerDelayMessageExample.java获取更多示例代码。 import org.apache.rocketmq.client.apis.ClientConfiguration; import
engine 是 String 消息引擎的类型。支持的类型为rocketmq。 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 type 否
s/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数
</dependency> 发送事务消息 参考如下示例代码,或者通过ProducerTransactionMessageExample.java获取更多示例代码。 import org.apache.rocketmq.client.apis.ClientConfiguration; import
ers/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 user_name 是 String 用户名。 请求参数 表2 请求Body参数
/v2/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 表2 Query参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎:rocketmq。 name
ance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 action
valueOf(deliverTimestamp)); // 设置要取消消息的ID,为发送消息的唯一ID(UNIQUE_KEY),可以从发送消息的结果中获取 cancelMsg.putUserProperty("__CANCEL_SCHEDULED_MSG", sendResult
ce_id}/metadata 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 overwrite
ance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 action
instance fails to be obtained from the handler. handler不存在,获取消费实例失败,可能是因为1分钟后消费实例释放,导致从handler获取consumer实例失败。 请检查handler 400 DMS.10542206 The value of