-
创建Kafka消费组 - 分布式消息服务Kafka版
如果在配置参数中设置“auto.create.groups.enable”为“true”,则该操作为可选。 如果在配置参数中设置“auto.create.groups.enable”为“false”,在消费消息前,需要先创建消费组,否则会导致消费失败。
-
消息超过老化时间,消息仍存在的原因 - 分布式消息服务Kafka版
仅在Topic中未设置老化时间时,“配置参数”中的log.retention.hours值才会对此Topic生效。),消息仍存在。
-
查询产品规格列表 - 分布式消息服务Kafka版
查询产品规格列表 功能介绍 在创建Kafka实例时,需要配置订购的产品ID(即product_id),可通过该接口查询产品规格。
-
实例版本在控制台和Kafka Manager上显示不一致? - 分布式消息服务Kafka版
Kafka Manager使用了开源Kafka 2.2.0的公共信息配置,所以显示的版本是2.2.0,和购买的Kafka实例版本没有关系。 父主题: 实例问题
-
Kafka数据迁移概述 - 分布式消息服务Kafka版
在云上变更业务部署 单AZ部署的Kafka实例,不具备AZ之间的容灾能力。用户对可靠性要求提升后,需要迁移到多AZ部署的实例上。 约束与限制 使用Smart Connect迁移业务,会对源端Kafka进行消费,对目标端Kafka进行生产,会占用源端和目标端Kafka的带宽。
-
变更Kafka实例规格 - 分布式消息服务Kafka版
多副本的Topic需要在生产客户端配置重试机制,方法如下: 生产客户端为Kafka开源客户端时,检查是否配置retries参数,建议此参数值设置为3~5。 生产客户端为Flink客户端时,检查是否配置重启策略,配置重启策略可以参考如下代码。
-
错误码 - 分布式消息服务Kafka版
实例升级未找到新版本安装包。 请重新选择升级的版本号 400 DMS.00400052 only the instance at running status can upgrade. 实例升级状态必须是RUNNING。
-
Kafka实例创建Topic失败 - 分布式消息服务Kafka版
不同规格实例配置的分区数上限不同,具体请参考产品规格。 解决方案:对Kafka实例扩容,或者删除不需要的Topic。 父主题: Topic和分区问题
-
Kafka实例的Topic数量是否有限制? - 分布式消息服务Kafka版
不同规格配置的Topic总分区数不同,如下表所示。
-
spring-kafka的使用 - 分布式消息服务Kafka版
## 安全协议为“SASL_SSL”时,配置信息如下。
-
为什么限制Topic的总分区数? - 分布式消息服务Kafka版
不同规格配置的Topic总分区数不同,如下表所示。
-
管理Smart Connect任务 - 分布式消息服务Kafka版
如果Smart Connect任务没有配置源端信息/目标端信息,在Smart Connect任务详情页面不显示源端信息/目标端信息。 删除Smart Connect任务 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择Kafka实例所在的区域。
-
查询可用区信息 - 分布式消息服务Kafka版
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。
-
Kafka Manager概述 - 分布式消息服务Kafka版
图中④区域表示队列的配置信息。详情参考Kafka队列官方配置文档(https://kafka.apache.org/documentation/#topicconfigs)。 图中⑤区域表示队列监控数据统计。
-
Kafka业务使用流程 - 分布式消息服务Kafka版
购买Kafka实例 Kafka实例采用物理隔离的方式部署,租户独占Kafka实例。 创建Kafka Topic 创建用于存储消息的Topic,供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接Kafka实例,并生产消费消息。
-
实例管理 - 分布式消息服务Kafka版
查询用户/客户端流控配置 创建用户/客户端流控配置 修改用户/客户端流控配置 重置消费组消费进度到指定位置 父主题: API V2(推荐)
-
在Windows服务器中无法登录Kafka Manager - 分布式消息服务Kafka版
检查安全组是否配置正确?安全组的配置请参考选择和配置安全组。 是,执行3。 否,修改安全组配置。 在Kafka实例控制台,重启Kafka Manager,具体操作请参考重启Kafka Manager。
-
Kafka连接问题排查和解决 - 分布式消息服务Kafka版
检查安全组规则是否配置正确。请参考如何选择和配置安全组。 检查Consumer和Producer的配置 查看日志,检查Consumer和Producer初始化时打印的参数是否符合预期,是否和自己在配置文件中设置的一致。 如果不一致,请检查配置文件的写法。
-
API概览 - 分布式消息服务Kafka版
、查询用户/客户端流控配置、创建用户/客户端流控配置、修改用户/客户端流控配置、重置消费组消费进度到指定位置。
-
连接实例 - 分布式消息服务Kafka版
连接实例 配置Kafka网络连接 配置Kafka访问控制 配置Kafka客户端 使用客户端连接Kafka(明文接入) 使用客户端连接Kafka(密文接入) 使用控制台连接Kafka