百度消息服务封装了Kafka集群细节,并以托管服务形式提供,您可以直接使用百度消息服务创建主题来集成大规模分布式应用,而无需考虑集群运维,仅按照使用量支付处理数据的费用。相对于传统的消息服务,百度消息服务有以下特点: 可通过分区(Partition)实现主题水平扩展。 分区分布在多个节点上以达到高通量。
概述 概述 本系列文档将为您介绍使用专享版消息服务 for Kafka的基本流程,由通过控制台创建Kafka专享版集群实例、创建主题、配置用户权限、客户端设置,直至最终完成消息收发,帮助您加速熟悉过程,成功对接业务。 除了本文档中介绍的方法,您也可以使用API直接对实例进行相关管理操作。
优势 高可用 调度服务实时监控RabbitMQ服务状态,并提供RabbitMQ服务的创建、查询等服务。一个调度服务故障后可以自动切换,不影响对外提供服务,保证服务的高可用。 高可靠 服务隔离:RabbitMQ服务创建在用户的VPC内,网络上是一个逻辑隔离区,保证不同RabbitMQ实例数据的安全性。 租户隔离:RabbbitMQ的各租户间资源强隔离,互不影响,保证数据的安全性和稳定性。
连接服务 您可直接使用百度智能云提供的样例代码连接百度消息服务,也可从Kafka官网下载Kafka二进制包并逐步配置相关信息后连接百度消息服务。 通过样例代码连接服务 下载代码样例。请登录控制台,打开“产品服务>百度消息服务-证书”页,点击页面右上角“代码样例”,下载至本地,下载后解压。 百度消息服务提供的代码样例是Maven项目包。 运行样例代码。
概述 本文主要介绍如何通过各类开发语言来连接并使用专享版消息服务 for Kafka集群。 相关示例代码可参考: kafka-demo
业务迁移 本文主要介绍将自建Kafka集群迁移到专享版 消息服务 for Kafka集群的相关操作。 迁移前提 存在一个可用的专享版 消息服务 for Kafka。 为专享版 消息服务 for Kafka创建主题。 集群准备 1. 购买专享版消息服务for Kafka集群 开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 2.
START_KAFKA_SERVICE 启动 Kafka 服务 RESTART_KAFKA_SERVICE 重启 Kafka 服务 START_ZOOKEEPER_SERVICE 启动 ZooKeeper 服务 UPDATE_METADATA_FOR_CLUSTER 集群元数据信息更新 TOPIC_REASSIGN_PARTITION 主题重分区 CANCEL_REASSIGN_PARTITION
消息设置 概览 为了满足IDaaS用户在某些场景下需要接收消息通知的需求:1、IDaaS支持管理员用户配置邮件网关、短信网关;2、IDaaS支持在某些场景下(如创建新用户、密码即将到期等)向用户发送消息通知,并支持对模版内容进行自定义修改。 注意:完成配置邮件网关、短信网关是发送消息通知的前提。 消息网关设置 1、管理员用户进入 IDaaS > 项目 > 设置 > 消息设置 ,点击 网关设置 。
产品架构 服务架构 kafka 集群服务由多个 broker 组成,服务架构如下: 主题(Topic): 用于分类消息,可视为特定的消息流或消息队列,生产者向指定主题推送消息,消费者订阅主题并拉取消息。 消息节点(Kafka Broker): 组成 Kafka 集群服务的单个 kafka 进程,对应一台独立的 BCC 云主机。
例如,5KB消息按照一个记录收费,49KB消息按照两个记录收费,1MB消息按照40个记录收费。读写消息均计入记录数。 关于百度消息服务的更多信息,请至 产品描述 和 入门指南 。 计费 百度消息服务服务采用后付费方式,根据您的实际使用量实时计费,即您只需为使用的分区和传输的消息付费。具体的计费价格请参见: 价格详情页 。 注意:topic创建后,即算作分区使用中,分区计费项将会产生费用。