消息队列接口检查
社区干货
Redis 使用 List 实现消息队列有哪些利弊?|社区征文
Producer:消息生产者,负责产生和发送消息到 Broker;- Broker:消息处理中心。负责消息存储、确认、重试等,一般其中会包含多个 queue;- Consumer:消息消费者,负责从 Broker 中获取消息,并进行相应处理;> 消息队列的使用场景有哪些呢?消息队列在实际应用中包括如下四个场景:- 应用耦合:发送方、接收方系统之间不需要了解双方,只需要认识消息。多应用间通过消息队列对同一消息进行处理,避免调用接口失败导致整个过程失败;...
字节跳动新一代云原生消息队列实践
作者|字节跳动消息队列研发工程师-雷丽媛上文我们了解了在字节跳动内部业务快速增长的推动下,经典消息队列 Kafka 的劣势开始逐渐暴露,在弹性、规模、成本及运维方面都无法满足业务需求。因此字节消息队列团队... 故障检测及控制命令接入的工作。因为 BMQ 将数据放在分布式存储系统上,因此无需管理数据副本,相较于 Kafka 省去了 ISR 相关的管理。Controller 可以更加专注地关注集群整体流量均衡及故障检测。在 BMQ 中用户所...
字节跳动新一代云原生消息队列实践
字节跳动消息队列研发工程师-雷丽媛在字节跳动内部业务快速增长的推动下,经典消息队列 Kafka 的劣势开始逐渐暴露,在弹性、规模、成本及运维方面都无法满足业务需求。因此字节消息队列团队研发了计算存储分离的云... 故障检测及控制命令接入的工作。因为 BMQ 将数据放在分布式存储系统上,因此无需管理数据副本,相较于 Kafka 省去了 ISR 相关的管理。Controller 可以更加专注地关注集群整体流量均衡及故障检测。在 BMQ 中用户所...
字节跳动基于Apache Atlas的近实时消息同步能力优化 | 社区征文
对于Offset的维护不够灵活:我们的场景不能使用自动提交(会丢消息),而对于同一个Partition中的数据又要求一定程度的并行处理,使用Kafka Streaming的原生接口较难支持。- 与Kafka强绑定:大部分场景下,我们团队不是元数据消息队列的拥有者,也有团队使用RocketMQ等提供元数据变更,在应用层,我们希望使用同一套框架兼容。# 设计## 概念说明- MQ Type:Message Queue的类型,比如Kafka与RocketMQ。后续内容以Kafka为主,设...
特惠活动
消息队列接口检查-优选内容
消息队列接口检查-相关内容
Redis 使用 List 实现消息队列有哪些利弊?|社区征文
Producer:消息生产者,负责产生和发送消息到 Broker;- Broker:消息处理中心。负责消息存储、确认、重试等,一般其中会包含多个 queue;- Consumer:消息消费者,负责从 Broker 中获取消息,并进行相应处理;> 消息队列的使用场景有哪些呢?消息队列在实际应用中包括如下四个场景:- 应用耦合:发送方、接收方系统之间不需要了解双方,只需要认识消息。多应用间通过消息队列对同一消息进行处理,避免调用接口失败导致整个过程失败;...
ListKafkaConf
调用ListKafkaConf接口获取消息队列 Kafka版支持的相关配置。 使用说明 在创建消息队列 Kafka版之前,可以先通过此接口获取 Kafka 实例支持的配置,例如网络配置、规格信息、可用区等。 此接口的API Version为 2018-01-01。 此接口的调用频率限制为 100 次/s,超出频率限制会报错 “AccountFlowLimitExceeded”。 请求参数 无 响应参数 参数 类型 说明 AvailableVersions String 所有支持的Kafka版本列表。 ChargeTypes String 当前...
新功能发布记录
本文介绍了消息队列 RocketMQ版各特性版本的功能发布动态,新特性将在各个地域(Region)陆续发布,欢迎体验。 2024年3月功能名称 功能描述 发布地域 相关文档 云监控指标 增加实例维度的监控指标。 全部地域 查看监控数据 批量删除 Group 提供批量删除消费组的 API 接口(DeleteGroups)。 全部地域 DeleteGroups 2024年2月功能名称 功能描述 发布时间 发布地域 相关文档 云监控指标 增加实例、Topic 维度的监控指...
请求结构
本文介绍消息队列 RocketMQ版 API 请求的组成结构。 请求格式您可以通过发送 POST 请求来调用 RocketMQ 的 API 服务。HTTPS 请求的格式如下: Plain {URI-scheme}://{Endpoint}?Action={Action}&Version={Version}其... 消息队列 RocketMQ版的 Endpoint 为 rocketmq.volcengineapi.com,详细说明请参考服务地址。 Action:要执行的操作,此处请填写要调用的 API 接口。消息队列 RocketMQ版的 API 接口请参考 API 概览。 Version:API 版本...
请求结构
本文介绍消息队列 RocketMQ版 API 请求的组成结构。 请求格式您可以通过发送 POST 请求来调用 RocketMQ 的 API 服务。HTTPS 请求的格式如下: Plain {URI-scheme}://{Endpoint}?Action={Action}&Version={Version}其... 消息队列 RocketMQ版的 Endpoint 为 rocketmq.volcengineapi.com,详细说明请参考服务地址。 Action:要执行的操作,此处请填写要调用的 API 接口。消息队列 RocketMQ版的 API 接口请参考 API 概览。 Version:API 版本...
公共参数
本文介绍每个接口都需要使用的请求参数和返回参数。 请求URL参数参数 类型 是否必选 含义 Action String 必选 要执行的操作,如调用 DescribeInstances 查询已创建的消息队列 RocketMQ版实例。 Version String 必选 要使用的 API 版本,消息队列 RocketMQ版的 API 版本是 2023-01-01。 X-Expires Integer 可选 签名的有效时间,单位为秒,默认值为 900。 请求头参数参数名 类型 是否必选 含义 Content-Type St...
公共参数
本文介绍每个接口都需要使用的请求参数和返回参数。 请求URL参数参数 类型 是否必选 含义 Action String 必选 要执行的操作,如调用 DescribeInstances 查询已创建的消息队列 RocketMQ版实例。 Version String 必选 要使用的 API 版本,消息队列 RocketMQ版的 API 版本是 2021-04-01。 X-Expires Integer 可选 签名的有效时间,单位为秒,默认值为 900。 请求头参数参数名 类型 是否必选 含义 Content-Type St...
CreateInstance
调用 CreateInstance 接口创建 RabbitMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明使用消息队列 RabbitMQ版服务之前,请先通过 CreateInstance 接口创建 RabbitMQ 实例。 说明 通过 API 创建接口时暂不支持同时开启公网访问功能,如果需要开启实例的公网访问,建议在创建实例完成后,实例状态为运行中(Running)时,调用 CreateInstancePublicAccess 开启实例的公网访问。 默...
请求结构
本文介绍消息队列 RabbitMQ版 API 请求的组成结构。 请求URL您可以通过发送 HTTPS POST 请求来调用 RabbitMQ 的 API 服务。HTTPS 请求 URL 的格式如下: plaintext POST {URI-scheme}://{Endpoint}/?Action={Action... 消息队列 RabbitMQ版的 endpoint 为 rabbitmq.volcengineapi.com,详细说明请参考服务地址。 Action:要执行的操作,此处请填写要调用的API接口。消息队列 RabbitMQ版的API接口请参考API概览。 Version:API 版本号,格...
