检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
分布式消息服务RocketMQ版可以解除多个业务系统之间的耦合度，提升各系统的处理能力和响应速度。 分布式消息服务RocketMQ版提供的定时、延迟等能力，满足需要订阅通知的电商场景。 金融场景 相较于传统金融场景，互联网金融需要能及时响应互联网的快速变化。
查询可用区信息 功能介绍 在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码：200 表1 响应Body参数 参数 参数类型 描述 region_id
RocketMQ TCP协议的Python SDK只支持Linux系统，且不支持开启SSL。 发送事务消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
existed { fmt.Printf("unknow msg: %v, return Commit", msg) return primitive.CommitMessageState } state := v.
RocketMQ TCP协议的Python SDK只支持Linux系统，且不支持开启SSL。 发送顺序消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
the transaction resolution according to your business logic. // 检查本地事务并返回本地事务状态 return TransactionResolution.COMMIT;
LocalTransactionState executeLocalTransaction(Message message, Object o) { System.out.println("开始执行本地事务： " + message); return
public class TopicEntity { private String name; //Topic名称 private String messageType; //消息类型 public String getName() { return
context.setAutoCommit(true); System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return
消费端限流 在分布式消息服务RocketMQ版中，消费者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。
kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。
message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable,roma.user.manage.no.support,feature.physerver.kafka.pulbic.dynamic
约束与限制 RocketMQ TCP协议的Python SDK只支持Linux系统，且不支持开启SSL。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
existed { fmt.Printf("unknow msg: %v, return Commit", msg) return primitive.CommitMessageState } state := v.
系统会根据当前磁盘配置按比例执行扩容操作。例如扩容前实例的代理数为1，每个代理的磁盘大小为300GB，扩容后实例的代理数为2，此时单个代理的磁盘大小依旧为300GB，但是总磁盘大小为600GB。
final CompletableFuture<List<MessageView>> future0 = consumer.receiveAsync(maxMessageNum, invisibleDuration);
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。
support_features Object 参数解释： 支持的特性。 取值范围： 不涉及。 properties Object 参数解释： 产品特性。 取值范围： 不涉及。 available_zones Array of strings 参数解释： 可用分区。
support_features Array of RocketMQProductSupportFeaturesEntity objects 支持的特性功能。 qingtian_incompatible Boolean 是否为擎天实例。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
