操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,可以看到当前您已经创建的集群列表,集群列表默认按照集群的 创建时间 倒序排列。 如果集群数量较多,您可以通过 “ 集群名称 ”、“ 集群ID ”、“ 标签 进行快速搜索。 点击具体的集群,默认进入 集群详情 页面,能够看到集群的相关信息。
描述 type StoragePolicyType 存储策略类型,具体可参见: StoragePolicyType autoDelete AutoDelete 自动删除策略相关参数,具体可参见: AutoDelete AutoDelete 参数名称 类型 描述 diskUsedThresholdPercent Integer 磁盘容量阈值,达到该阈值后集群会按比例删除该磁盘上所有主题分区部分最早的消息
消息推送 广播消息 功能 向符合条件的所有设备发送消息。 为了避免消息通知被滥用,接口每天调用限制200次,滥用通知会被封禁请合理使用,单播推送不限制推送量,如确实需要频繁推送请使用单播或批量单播。
开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 迁移方案 方案一:先迁生产,后迁消费 先将生产消息的业务迁移到专享版 消息服务 for Kafka集群,这样原Kafka集群不会有新的消息生产。 待原有Kafka集群的消息全部消费完成后,再将消费消息业务迁移到专享版 消息服务 for Kafka集群,开始消费消息。
消息推送 消息推送 消息推送功能主要用户与客服人员双方会话消息的自动提醒。 用户侧通知:当客服向用户发送消息时,如果用户已经离开会话,系统将调用百度APP、微信、支付宝APP的消息通知能力通知用户及时查看消息。 客服侧通知:客服人员首先要绑定自己的微信账号。绑定完成后,当用户向客服发送消息时,客服人员的微信将收到消息通知,点击打开可以直接回应客户发送的消息。
死信队列:RabbitMQ支持消费失败消息、TTL过期消息、队列长度超限消息进入死信队列,且不重新发送到原来的队列消费,保证消息不丢失。 延时队列:RabbitMQ支持消息延时/定时发送,满足用户多个场景下的需求。
例如,5KB消息按照一个记录收费,49KB消息按照两个记录收费,1MB消息按照40个记录收费。读写消息均计入记录数。 关于百度消息服务的更多信息,请至 产品描述 和 入门指南 。 计费 百度消息服务服务采用后付费方式,根据您的实际使用量实时计费,即您只需为使用的分区和传输的消息付费。具体的计费价格请参见: 价格详情页 。 注意:topic创建后,即算作分区使用中,分区计费项将会产生费用。
产品架构 服务架构 kafka 集群服务由多个 broker 组成,服务架构如下: 主题(Topic): 用于分类消息,可视为特定的消息流或消息队列,生产者向指定主题推送消息,消费者订阅主题并拉取消息。 消息节点(Kafka Broker): 组成 Kafka 集群服务的单个 kafka 进程,对应一台独立的 BCC 云主机。
连接服务 您可直接使用百度智能云提供的样例代码连接百度消息服务,也可从Kafka官网下载Kafka二进制包并逐步配置相关信息后连接百度消息服务。 通过样例代码连接服务 下载代码样例。请登录控制台,打开“产品服务>百度消息服务-证书”页,点击页面右上角“代码样例”,下载至本地,下载后解压。 百度消息服务提供的代码样例是Maven项目包。 运行样例代码。
消息设置 概览 为了满足IDaaS用户在某些场景下需要接收消息通知的需求:1、IDaaS支持管理员用户配置邮件网关、短信网关;2、IDaaS支持在某些场景下(如创建新用户、密码即将到期等)向用户发送消息通知,并支持对模版内容进行自定义修改。 注意:完成配置邮件网关、短信网关是发送消息通知的前提。 消息网关设置 1、管理员用户进入 IDaaS > 项目 > 设置 > 消息设置 ,点击 网关设置 。