简介 Kafka API采用类似REST风格,提供对Kafka topic的创建与管理操作支持。如需基于topic进行读写操作,则可使用开源的 Kafka客户端 。 如果您是初次调用百度智能云产品的API,可以观看 API入门视频指南 ,快速掌握调用API的方法。
KAFKA KAFKA DDL FLINK SPARK CREATE TABLE kafka_table ( ` field01 ` STRING , ` field02 ` BIGINT , ` field03 ` FLOAT , ` field04 ` BINARY , ` field05 ` INT , ` field06 ` TINYINT , ` field07 ` BOOLEAN , `
api . bj . baidubce . com { name : demo , mode : HP , type : PROVISIONED , provisioned : { kafkaVersion : 2.7.2 , nodeType : kafka.g4.c2m8 , configMeta : { configId : null
服务域名 消息服务 for Kafka的服务域名为: Region Endpoint Protocol 北京 kafka-api.bj.baidubce.com HTTP and HTTPS 广州 kafka-api.gz.baidubce.com HTTP and HTTPS 苏州 kafka-api.su.baidubce.com HTTP and HTTPS 武汉 kafka-api.fwh.baidubce.com
服务域名 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
节点规格 Kafka.g4.c2m8 Kafka.g4.c4m16 Kafka.g4.c8m32 Kafka.g4.c16m64 Kafka.g4.c24m96 Kafka.g4.c32m128 注:以Kafka.g4.c2m8为例,该规格对应的底层虚机规格为2核vCPU+8GiB内存 节点数量 集群支持最小3节点,最大30节点。
公共响应头 下表为所有Kafka API的公共响应头域(HTTP协议的标准响应头域不再这里列出): 头域(Header) 说明 Content-Type 只支持JSON格式,application/json; charset=utf-8 x-bce-request-id Kafka后端生成,并自动设置到响应头域中 其中,“request id”使用UUID version4由Kafka服务生成。
01至KAFKA_10 isVisible boolean 标识accountId对于当前集群是否有权限; true为有权限,false为无权限;
计费项 百度智能云消息服务 for Kafka专享版服务计费项如下: 计费项 说明 实例规格 Kafka实例下各节点的配置规格。 各规格均为1:4的vCPU内存比(较高的内存比可供PageCache提升读写效率)。 磁盘容量 消息队列Kafka版支持的磁盘类型包括高性能云磁盘和增强型SSD。 不同磁盘类型的磁盘单价不同。 磁盘类型一经下单,不支持更改,请谨慎选择。
Kafka已配置好访问控制参数(无访问控制、SASL/PLAIN、SASL/SCRAM-SHA-256、SASL/SCRAM-SHA-512)。 确保Kafka的网络连通性,注意为DTS服务器开通 IP白名单 。 3. 将Kafka作为DTS源的注意事项 仅支持目标端为Kafka,暂不支持目标端为其他数据类型。