Consultthe service documentation for details. 400 Bad Request Authorization头域中附带的签名和服务端验证不一致。 消息服务 for Kafka错误码 在每个API接口的 错误码 部分会列出消息服务 for Kafka产生的错误码。
服务域名 Kafka API的服务域名为: Region Endpoint Protocol 北京 http://kafka-api.bj.baidubce.com/v1 HTTP and HTTPS 广州 http://kafka-api.gz.baidubce.com/v1 HTTP and HTTPS 苏州 http://kafka-api.su.baidubce.com/v1 HTTP and
概述 本文主要介绍如何通过各类开发语言来连接并使用专享版消息服务 for Kafka集群。 相关示例代码可参考: kafka-demo
产品架构 服务架构 kafka 集群服务由多个 broker 组成,服务架构如下: 主题(Topic): 用于分类消息,可视为特定的消息流或消息队列,生产者向指定主题推送消息,消费者订阅主题并拉取消息。 消息节点(Kafka Broker): 组成 Kafka 集群服务的单个 kafka 进程,对应一台独立的 BCC 云主机。
介绍 百度消息服务 for RabbitMQ是百度智能云基于开源 RabbitMQ 推出的全托管的消息队列产品,提供完全兼容AMQP(Advanced Message Queuing Protocol 高级消息队列协议)协议、稳定可靠、高性能的消息队列服务。RabbitMQ采用全托管模式, 用户即开即用,免去部署、维护的工作量和费用,最大化提升业务效率。
节点监控 节点监控用于展示集群中每个节点上的监控指标,分为 服务监控 和 主机监控 。 服务监控 服务监控主要是各个节点中Kafka服务相关的监控指标。比如每个节点的生产消息速率、生产消息流量等指标。 您可以在右上角的 指标筛选 中选择更多的监控指标。 主机监控 主机监控主要是各个节点本身的监控指标,比如CPU使用率、内存使用率等指标。 您可以在右上角的 指标筛选 中选择更多的监控指标。
系统策略对主用户的所有消息服务 for RabbitMQ 资源生效,用户不能随意修改。 自定义策略中,用户可以指定任一实例级别的资源,实现更细粒度的资源配置。 1.
500 服务内部错误 请求示例 Java 复制 1 GET http : / / kafka - api . bj . baidubce . com / v2 / clusters / 33 a168bb70c0459787416077114ab233 / consumer - groups / demo - group - test / topics 2 Authorization : bce
使用限制 使用前提 对分布式系统和消息队列的基本概念有一定的了解,以便更好地理解和配置 Kafka。 具备一定的硬件资源,包括足够的内存、CPU 和磁盘空间,以支持 Kafka 服务器的运行和数据存储。 规划好主题(Topic)、分区(Partition)和副本(Replication)的设计,以满足业务需求和性能要求。 确定合适的消息保留策略,根据业务需求设置消息的保留时间和清理机制。