检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
com.huaweicloud.sdk.rocketmq.v2.model.*; import java.io.*; import java.util.List; import java.util.ArrayList; public class CreateBatchTopicSolution
"valid_values" : "1~720", "value_type" : "integer" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
查询主题消费组列表成功。 { "groups" : [ "CID_JODIE_1", "test_consumer" ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
实例规格变更成功。 { "job_id" : "93b94287-728d-4bb1-a158-cb66cb0854e7" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
{ "policies" : [ ], "total" : 0, "name" : "test" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
"name" : "fileReservedTime", "value" : 72 } ] } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改RocketMQ配置的参数，将文件保留时间修改为72小时。 1 2 3 4 5
产品规格 分布式消息服务RocketMQ版兼容开源RocketMQ 4.8.0和5.x，具体产品规格如下。 RocketMQ对消息的处理能力依赖于磁盘的吞吐能力，性能基线基于超高I/O及以上磁盘类型，高I/O磁盘类型可能无法达到当前标准。 分布式消息服务RocketMQ版4.8.0规格
"DMS.00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 重发死信消息。 1 2 3 4 5 6 7 8 9 10 11 12 13
批量修改消费组成功。 { "job_id" : "8abfa7b27da211df017da340427b0979" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 批量修改消费组的参数，将consumer-group-test消费组的最大重试次数修改为16。
"key" : "key2", "value" : "value2" } ] } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建两个实例标签，标签名为key1、key2，值为value1、value2。 1 2
"consumer_offset" : 0, "last_message_time" : 0 } ] } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
使用客户端连接RocketMQ（开启SSL） 实例开启SSL时，数据使用加密传输，安全性更高。本文主要介绍在Linux系统的命令行模式下，调用TCP协议连接已开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中，将“SSL”配置为“SSL”或“PERMISSIVE”（通过密文传输），即为已开启SSL。
168.0.91:10101", "queue_id" : 0, "queue_offset" : 0 } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 导出主题中指定消息ID和Key的死信消息。 1 2 3 4 5 6 7 8
"type" : "TAG", "expression" : "tagA" } ] } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
场景，借助实例诊断功能可以帮助您快速定位问题。 支持区域： 全部 实例诊断 收发消息 使用RocketMQ开源客户端访问分布式消息服务RocketMQ版来收发消息的示例代码。 支持区域： 全部 收发普通消息 收发顺序消息 收发事务消息 定时消息 分布式消息服务RocketMQ版支
Q实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK，并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1.8.0_231 export PATH=$JAVA_HOME/bin:$PATH
"**************", "topic_perms" : [ ], "white_remote_address" : "" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建一个非管理员的用户，授予发布、订阅topic1和group1的权限。 1 2 3
true, "retry_max_time" : 16, "broadcast" : true } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改consumer-group-test消费组的参数，最大重试次数修改为16。 1 2
0，获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
"**************", "topic_perms" : [ ], "white_remote_address" : "" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改用户参数，授予user_name用户发布、订阅topic1和group1的权限。 1
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
