作者|字节跳动消息队列研发工程师-雷丽媛上文我们了解了在字节跳动内部业务快速增长的推动下,经典消息队列 Kafka 的劣势开始逐渐暴露,在弹性、规模、成本及运维方面都无法满足业务需求。因此字节消息队列团队... 因此 BMQ 的 Metadata 中的 ‘Broker’ 信息实际上填写的是 BMQ 中 Proxy 的信息,客户端根据 Metadata 请求将生产和消费等请求发送到对应的 Proxy,再由 Proxy 处理或转发。这样的架构有助于 BMQ 做更多的容错工作。...
# 问题描述开启公网连接后,如何使用 Python 正常连接到 Kafka 进行生产和消费。# 问题分析在公网环境下,消息队列 Kafka 版要求通过 SSL 证书对消息进行鉴权和加密,保障数据传输过程的安全性,防止数据在网络传输过程中被截取或者窃听,相较于普通公网访问方式具备更高的安全性。目前支持客户端对服务端证书的单向认证, 所以需要下载 SASL_SSL 证书 并指定 SASL_SSL 协议。# 解决方案Python 示例demo如下:```pythonfrom kaf...
字节跳动消息队列研发工程师-雷丽媛在字节跳动内部业务快速增长的推动下,经典消息队列 Kafka 的劣势开始逐渐暴露,在弹性、规模、成本及运维方面都无法满足业务需求。因此字节消息队列团队研发了计算存储分离的云... 因此 BMQ 的 Metadata 中的 ‘Broker’ 信息实际上填写的是 BMQ 中 Proxy 的信息,客户端根据 Metadata 请求将生产和消费等请求发送到对应的 Proxy,再由 Proxy 处理或转发。这样的架构有助于 BMQ 做更多的容错工作。...
消息队列则是双方规定好通信的消息格式,各自都只要发消息给消息队列就可以了。可以保证不同开发语言开发的系统之间的通信。2、消息的可靠性:所有系统之间提交的消息有消息队列里的messagerouter来投递。根据一个发送方指定的地址并转发到另外一个地方。同时,消息队列也根据不同的需要将消息进行持久化,这样保证消息在投递的过程中不会被丢失。3、系统可靠性:集成系统中有一方出现故障,不影响系统之间的通信,保证了有效信息的...
通过消息队列 Kafka版控制台或 OpenAPI 查看指定实例的 Group 列表时,发现列表中的 Group 数量比手动创建的数量更多,即出现了一些非手动创建的 Group。该现象的主要原因如下: 开启了自由使用 Group 功能,消息队列 ... 开启自由使用 Group 功能后,您可以直接在消费 SDK 中指定一个符合命名要求的 Group ID 进行消费,此 Group 会显示在实例的 Group 列表中。 创建并启动了 Connctor 任务。 Connector 任务启动后,消息队列 Kafka版会自...
如果需要通过公网访问消息队列 Kafka版实例,请先申请同地域的 EIP,详细操作步骤请参考申请公网 IP。 默认情况下,您可以在每个地域中创建 8 个 Kafka 实例,每个账号在每个地域中的所有实例存储容量总和最大为 90Ti... 详细信息请参考数据结构文档中 ChargeInfoObject 部分。 UserName String 否 Test1 SASL/PLAIN 用户名称。应符合以下要求: 由字母、数字、连字符(-)或下划线组成。 长度为 3~64 个字符。 用户名不支持设置为 ...
且子网中有至少 6 个空闲的内网 IP 地址。创建实例后,不可更改实例所在的私有网络。 如果需要通过公网访问消息队列 Kafka版实例,请先申请同地域的 EIP,建议绑定的 EIP 带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 注意事项默认情况下,您可以在每个地域中创建 8 个 Kafka 实例,每个账号在每个地域中的所有实例存储容量总和最大为 90TiB,否则创建实例时报错The instance_num/storage_sum has exceeded ...
应用接入消息队列 RocketMQ版之前,需要在控制台创建 RocketMQ 实例。消息队列 RocketMQ版提供多种实例规格,对应不同的计算能力和存储空间,您可以根据实际业务需求选择不同的实例规格。本文档介绍创建 RocketMQ 实例的操作步骤。 说明 默认情况下,您可以在每个地域中创建 5 个 RocketMQ 实例,且每个账号在每个地域中的所有实例存储容量总和最大为 10TiB,否则创建实例时报错 The InstanceNum/StorageSum has exceeded quota。如需提...
本文档介绍消息队列 Kafka版各种常见场景下的自定义访问策略示例。 指定实例的只读权限被授予以下权限策略后,IAM 用户可以通过控制台或 OpenAPI 查看指定实例的配置及接入点等基本信息、查看 Topic列表和分区详情、... IAM 用户可以通过控制台或 OpenAPI 查看并管理指定实例所有信息,包括升级实例规格、开启或关闭公网访问等实例管理操作,以及实例中 Topic、Group、SASL 用户等其他资源的所有管理操作。 JSON { "Statement": [ ...
消息队列 Kafka版提供以下相关API 接口。 实例管理API 说明 ListKafkaConf 调用 ListKafkaConf 接口获取消息队列 Kafka版支持的相关配置。 CreateKafkaInstance 调用 CreateKafkaInstance 接口创建Kafka实例。 DeleteKafkaInstance 调用 DeleteKafkaInstance 接口删除Kafka实例。 DescribeInstanceDetail 调用 DescribeInstanceDetail 接口获取指定Kafka实例的详细信息。 DescribeInstancesSummary 调用 DescribeInstancesSumm...
使用说明在消息队列 RabbitMQ版控制台中创建实例之后,实例插件默认为关闭状态,您可以手动为实例开启插件。目前消息队列 RabbitMQ版支持在控制台开启以下插件: 插件名称 功能描述 端口号 rabbitmq_mqtt 表示实... 消息丢失。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 rbtmq-******* 实例ID。 PluginStatusList List 必选 待修改状态的插件列表。详细信息请参考 PluginStatus。 说...
消息队列 Kafka版提供多种实例规格供您选择,你可以根据业务的读写流量峰值、所需的存储空间大小和分区数量估算计算规格与存储规格。 读写流量:购买时选择网卡读流量峰值和网卡写流量峰值中的较大值进行评估。 建议... 冗余消息也可能带来额外的空间占用,实际可用存储会小于设置的存储规格,建议预留 25% 左右的存储空间。 分区数量:根据实际的业务需求设置分区数量。每个计算规格提供一定的免费分区额度,您也可以选购更多的分区。 ...
2 发送消息 实现方法创建消息发送程序 producer.go。 编译并运行 producer.go 发送消息。 查看运行结果。运行结果示例如下。 说明 消息队列 Kafka版提供示例项目供您快速接入,下载并解压缩 Demo 后,可以直接执行以下命令发送并消费消息。 undefined go run -mod=vendor {DemoPath}/kafka.go```` 示例代码通过默认接入点生产消息的示例代码如下,您也可以参考 Demo 中的示例文件 {DemoPath}/client/producer.go,实现相关业务逻辑...