g 实例ID instanceName String 实例名称 instanceStatus String 实例状态 instanceType String 实例类型:单机(Single),集群(Cluster) description String 实例描述信息 engine String 消息引擎
0.004元/百万个记录 消息传输记录数阶梯 单价 0-2亿条(含) 0.007元/百万个记录 2亿(不含)-20亿条(含) 0.006元/百万个记录 20亿(不含)-50亿条(含) 0.005元/百万个记录 大于50亿条 0.004元/百万个记录 消息传输记录数阶梯 单价 0-2亿条(含) 0.007元/百万个记录 2亿(不含)-20亿条(含) 0.006元/百万个记录 20亿(不含)-50亿条(
消息服务for Kafka-专享版 消息服务 for Kafka-专享版包含5种监控对象类型,分别是:服务监控(Broker)、主题监控(Topic)、主机监控(Node)、集群监控(Cluster)、消费组监控(ConsumerGroup),各个类型包含的监控指标列表如下: 服务监控(Broker) 指标英文名称(metric name) 指标中文名称 单位 维度 备注 ActiveControllerCount
MessagePublishRateQueue 队列发布消息速度 条/秒 InstanceId,QueueName Messages 实例消息数 条 InstanceId MessagesReady 实例可消费消息数 条 InstanceId MessagesReadyQueue 队列可消费消息数 条 InstanceId,QueueName MessagesUnacknowledged 实例未确认消息数
消息队列和事件驱动架构 Kafka可以作为消息队列使用,用于处理异步消息和事件驱动的架构,支持消息的发布订阅和消息的队列处理。 大数据处理和流处理 Kafka可以与大数据处理框架如Hadoop、Spark、Flink等集成,支持大规模数据的处理和分析,实现实时数据流处理和批处理任务。
步骤三:配置权限认证 概述 本文介绍在完成消息服务 for Kafka专享版集群创建后,如何通过管理控制台进行权限及认证相关的配置。
通用说明 API调用遵循HTTP协议,各Region采用不同的域名,具体域名见 服务域名 。数据交换格式为JSON,所有request/response body内容均采用UTF-8编码。 实名认证 使用Kafka API的用户需要实名认证,没有通过实名认证的可以前往 百度开放云官网控制台 中的安全认证下的实名认证中进
消息(Message) 消息队列服务对外服务的基本实体单元,消息由Header(标签)和Body(消息体)组成。Header是消息生产者添加的各种属性的集合,包括消息是否被持久化,由哪个队列接受,优先级是多少等等。Body是消息体,是真正需要被传输的数据。 队列(Queue) 消息的容器,存储被生产者投递过来但尚未被消费的消息。生产者把消息发送到队列,消费者从队列中获取并消费消息。
接口说明 Topic相关接口 创建Topic 描述 本接口用于创建一个Kafka topic。 请求 请求结构 Plain Text 复制 1 POST /v{version}/topic?clientToken={clientToken} HTTP/1.1 2 { 3 "topicName": &
变配规则说明 用户可以根据需要变更实例配置,具体的变配及计费说明如下: 计费方式 变配规则 计费说明 预付费—包年包月 支持升级配置,不支持降级配置。 以天为最小计费单位,不足一天按一天计。 变更配置实例是否享受预付费折扣,以剩余时间长度是否满1年、2年、3年为准。 升级需付金额=(合同剩余天数/合同总天数)×(新实例