-
修改主题 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
创建主题或批量删除主题 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
查询主题的授权用户列表 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
修改实例信息 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
创建用户并授权使用DMS for RocketMQ - 分布式消息服务RocketMQ版
cketMQ实例,如果无法购买RocketMQ实例(假设当前权限仅包含DMS ReadOnlyAccess),表示“DMS ReadOnlyAccess”已生效。 在“服务列表”中选择云硬盘(假设当前策略仅包含DMS ReadOnlyAccess),若提示权限不足,表示“DMS ReadOnlyAccess”已生效。
-
重发死信消息 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
消费验证 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
认证鉴权 - 分布式消息服务RocketMQ版
"password": "********", "domain": { "name": "domainname" } }
-
开启RocketMQ消息轨迹 - 分布式消息服务RocketMQ版
ient-go/v2 v2.1.0 ) 生产者开启消息轨迹(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 package main import ( "context" "fmt" "os" "time" "github.com/apache/rocketmq-client-go/v2"
-
批量修改消费组 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
获取项目ID - 分布式消息服务RocketMQ版
"projects": [ { "domain_id": "65382450e8f64ac0870cd180d14e684b", "is_domain": false, "parent_id": "
-
修改用户参数 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
分布式消息服务RocketMQ版 - 分布式消息服务RocketMQ版
修改Topic参数 变更实例规格 RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数,如果需要可以分别进行扩容。 当前只支持扩容,不支持缩容。扩容存储空间有次数限制,只能扩容20次。 支持区域: 华北-北京一 华北-北京四 华东-上海一
-
查看和修改RocketMQ实例基本信息 - 分布式消息服务RocketMQ版
RocketMQ实例正在进行重启操作。 变更中 RocketMQ实例正在进行公网访问变更或规格变更操作。 变更失败 RocketMQ实例处于公网访问变更失败或规格变更失败的状态。 已冻结 实例处于已冻结状态。 冻结中 实例从运行中到已冻结的中间状态。 升级中 RocketMQ实例正在进行升级操作。
-
新建元数据迁移任务 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
成本管理 - 分布式消息服务RocketMQ版
企业可以使用成本中心的“成本单元”来拆分公共成本。公共成本是指多个部门共享的计算、网络、存储或资源包产生的云成本,或无法直接通过企业项目、成本标签分配的云成本。这些成本不能直接归属于单一所有者,因此不能直接归属到某一类别。使用拆分规则,可以在各团队或业务部门之间公平地分配这些成本。详细介绍请参见使用成本单元查看成本分配。
-
收发顺序消息 - 分布式消息服务RocketMQ版
' msgId: ' + ret.msg_id) producer.shutdown() if __name__ == '__main__': send_orderly_with_sharding_key() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。
-
通过消息幂等实现消息去重 - 分布式消息服务RocketMQ版
消费者消费消息时,服务端将消息投递至消费者并完成业务处理。如果此时发生网络闪断,导致消费者提交offset失败,服务端的offset未及时更新,此时服务端会认为消息投递失败。为了保证消息至少被消费一次,服务端会尝试投递之前已被处理过的消息,最终消费者就会收到与之前处理过的Message
-
收发普通消息 - 分布式消息服务RocketMQ版
' msgId: ' + ret.msg_id) producer.shutdown() if __name__ == '__main__': send_message_sync() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。
-
审计与日志 - 分布式消息服务RocketMQ版
云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS for