公网SASL_SSL方式生产和消费消息 在 Kafka 集群所在 VPC 网络外访问,使用 SASL_SSL 协议接入,接入点可以在 集群详情 页面查看。 环境准备 安装1.8或以上版本 JDK 安装2.5或以上版本 Maven 集群准备 1. 购买专享版消息服务for Kafka集群 开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 2.
服务监控 服务监控主要是各个节点中Kafka服务相关的监控指标。比如每个节点的生产消息速率、生产消息流量等指标。 可以在右上角的 指标筛选 中选择更多的监控指标。 主机监控 主机监控主要是各个节点本身的监控指标,比如CPU使用率、内存使用率等指标。 可以在右上角的 指标筛选 中选择更多的监控指标。
例如,5KB消息按照一个记录收费,49KB消息按照两个记录收费,1MB消息按照40个记录收费。读写消息均计入记录数。 关于百度消息服务的更多信息,请至 产品描述 和 入门指南 。 计费 百度消息服务服务采用后付费方式,根据您的实际使用量实时计费,即您只需为使用的分区和传输的消息付费。具体的计费价格请参见: 价格详情页 。 注意:topic创建后,即算作分区使用中,分区计费项将会产生费用。
购买专享版消息服务for Kafka集群 开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 2. 为购买的集群创建主题 在控制台页面点击集群名称,进入集群详情页面。 在左侧的边栏中点击『主题管理』,进入主题管理页面。 在主题管理页面点击『创建主题』,进行主题的创建。 使用步骤: 步骤一:获取集群接入点 具体请参考: 接入点查看 。
续费说明 消息服务 for Kafka专享版支持手动续费和自动续费两种续费方式,用户可以根据不同的应用场景选择合适的续费方式,推荐使用自动续费。两种不同续费方式的使用场景如下: 手动续费:初期使用消息服务 for Kafka专享版 ,有运维人员按时进行续费操作; 自动续费:适用于长期使用消息服务 for Kafka专享版 ,对服务可用性、数据安全性、运维自动化要求更高的场景。
公共响应头 公共头部 描述 Content-Type application/json; charset=utf-8 x-bce-request-id 消息服务 for Kafka后端生成,并自动设置到响应头域中 其中,x-bce-request-id 使用UUID version4由消息服务 for Kafka服务生成。
Consultthe service documentation for details. 400 Bad Request Authorization头域中附带的签名和服务端验证不一致。 消息服务 for Kafka错误码 在每个API接口的 错误码 部分会列出消息服务 for Kafka产生的错误码。
监控报警 查看监控 进入“产品服务>百度消息服务>主题”,点击要查看的主题名称,在详情页面中可看到监控数据图。 主题监控 可以查看该topic每秒读写的数据量(单位字节/秒),以及写入的消息个数(单位个/秒) 消费监控 在监控页面的右上角“消费组”处选择消费当前topic的消费组,若列表中没有所有查看的消费组,可通过输入消费组ID进行搜索查看。
前提条件 集群必须处于 服务中 状态。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,点击需要操作的集群。 在 主题管理 中点击 创建主题 按钮,输入主题名称、分区数、副本数等信息。 在创建主题时,也可以对主题设置一些高级配置项。 通过API创建主题 您可以通过 创建主题 来创建主题。