-
与RabbitMQ、RocketMQ的差异 - 分布式消息服务Kafka版
流量控制 待规划 支持client和user级别,通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credit-Based算法,是内部被动触发的保护机制,作用于生产者层面。 消息顺序性 单队列(queue)内有序 支持单分区(partition)级别的顺序性。 不
-
业务过载处理建议 - 分布式消息服务Kafka版
在CPU资源情况可控的情况下,使用压缩算法对数据进行压缩。 常用的压缩算法包括:ZIP,GZIP,SNAPPY,LZ4等。选择压缩算法时,需考虑数据的压缩率和压缩耗时。通常压缩率越高的算法,压缩耗时也越高。对于性能要求高的系统,可以选择压缩速度快的算法,比如LZ4;对于需要更高压缩比的
-
配置Kafka间的数据复制 - 分布式消息服务Kafka版
factor”。 启动偏移量 支持两种偏移量: 最早:最小偏移量,即获取最早的数据。 最新:最大偏移量,即获取最新的数据。 压缩算法 复制消息所使用的压缩算法。 topic映射 通过Topic映射,您可以自定义目标端Topic名称。 最多新增20个Topic映射。不能同时设置“重命名Topic”和“topic映射”。
-
认证鉴权 - 分布式消息服务Kafka版
Access Key):与访问密钥ID结合使用的密钥,对请求进行加密签名,可标识发送方,并防止请求被修改。 使用AK/SK认证时,您可以基于签名算法使用AK/SK对请求进行签名,也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。 签名SDK只
-
购买Kafka实例 - 分布式消息服务Kafka版
支持SCRAM-SHA-512机制和PLAIN机制。 什么是SCRAM-SHA-512机制和PLAIN机制? SCRAM-SHA-512机制:采用哈希算法对用户名与密码生成凭证,进行身份校验的安全认证机制,比PLAIN机制安全性更高。 PLAIN机制:一种简单的用户名密码校验机制。 SASL_PLAINTEXT
-
配置Kafka实例的明文/密文接入 - 分布式消息服务Kafka版
支持SCRAM-SHA-512机制和PLAIN机制。 什么是SCRAM-SHA-512机制和PLAIN机制? SCRAM-SHA-512机制:采用哈希算法对用户名与密码生成凭证,进行身份校验的安全认证机制,比PLAIN机制安全性更高。 PLAIN机制:一种简单的用户名密码校验机制。 SASL_PLAINTEXT
-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
启动偏移量,latest为获取最新的数据,earliest为获取最早的数据。(仅源端类型为Kafka时会显示) compression_type String 压缩算法。(仅源端类型为Kafka时会显示) topics_mapping String topic映射。(仅源端类型为Kafka时会显示) 表4
-
与开源Kafka的差异 - 分布式消息服务Kafka版
升级。 使用开源软件成熟度低,无法保证关键业务,商业案例少;自研周期长,并需要长时间进行验证。 能力强大 100%兼容开源,支持一键扩容,深度优化开源代码提升性能和可靠性,支持消息查询、消息转储等高级特性。 功能不完善,需额外投入进行开发。 稳定可靠 稳定高可用 支持跨AZ部署,
-
查询Smart Connect任务列表 - 分布式消息服务Kafka版
启动偏移量,latest为获取最新的数据,earliest为获取最早的数据。(仅源端类型为Kafka时会显示) compression_type String 压缩算法。(仅源端类型为Kafka时会显示) topics_mapping String topic映射。(仅源端类型为Kafka时会显示) 表6
-
创建Smart Connect任务 - 分布式消息服务Kafka版
liest为获取最早的数据。(仅源端类型为Kafka时需要填写) compression_type 否 String 复制消息所使用的压缩算法。(仅源端类型为Kafka时需要填写) none gzip snappy lz4 zstd topics_mapping 否 String
-
错误码 - 分布式消息服务Kafka版
factor larger than available brokers. 创建Topic的副本数大于当前可用的Broker数。 请联系技术支持工程师协助解决。 400 DMS.00400867 Failed to create the Smart Connect task. 创建connector