检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
为什么不建议使用Sarama客户端收发消息? 问题现象 使用Sarama客户端收发消息可能存在以下问题: Sarama客户端无法感知分区变化,当Topic分区数增加时,需要重启客户端后才能正常消费。 Sarama客户端消息最大处理时间(MaxProcessingTime)默认值为
删除单个转储任务 功能介绍 删除单个转储任务。 当前页面API为历史版本API,未来可能停止维护。请使用删除Smart Connector任务。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/connectors/{connector_
查询分区最早消息的位置 功能介绍 查询分区最早消息的位置。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partit
修改Kafka的接入方式 功能介绍 修改Kafka的内网或者公网接入方式。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/{engine}/instances/{instance_id}/plain-ssl-switch 表1 路径参数 参数
使用主账号或者“admin”用户组中的子账号登录Kafka控制台。 在管理控制台左上角单击,选择区域。 在左侧导航栏选择“全局配置 > 服务授权”,进入“服务授权”页面。 勾选“访问费用中心服务”,单击“更新授权”。 授权成功后,会在IAM中创建名为“dms_admin_trust”的委托。 “dms_a
Kafka Manager能否查询到消息的正文? Kafka Manager无法查询到消息的正文。 父主题: Kafka Manager问题
Kafka Manager WebUI的端口能否修改? Kafka Manager WebUI的端口不支持修改。 父主题: Kafka Manager问题
创建消费组 功能介绍 实例创建消费组 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/group 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
查询Smart Connect任务详情 功能介绍 查询Smart Connect任务详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} 表1
修改Kafka实例Topic 功能介绍 修改Kafka实例Topic 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id
校验Connector连通性 功能介绍 校验Connector连通性。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/connector/validate 表1 路径参数 参数 是否必选 参数类型
取值范围: true:是controller节点。 false:不是controller节点。 version String 参数解释: 服务端版本。 取值范围: 1.1.0 2.7 3.x register_time Long 参数解释: broker注册时间,为unix时间戳格式。
Kafka实例创建后,能修改VPC和子网吗? 不能修改VPC和子网。 父主题: 实例问题
Kafka实例的内网连接地址可以修改吗? 不支持修改,且不支持指定IP地址。 父主题: 连接问题
消息超过老化时间,消息仍存在的原因 问题现象:消息超过设置的老化时间(如果Topic已经设置了老化时间,此时“实例管理 > 配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时,“实例管理 > 配置参数”中的log.retention
关闭Smart Connect 如果不再使用Smart Connect相关功能,您可以关闭Smart Connect,释放资源。 关闭Smart Connect不会影响业务。 约束与限制 关闭Smart Connect后,实例会停止收取用于Smart Connect的代理费用,并自动删除用于Smart
实例扩容 功能介绍 实例规格变更。 当前页面API为历史版本API,未来可能停止维护。请使用实例扩容。 URI POST /v2/{engine}/{project_id}/instances/{instance_id}/extend 表1 路径参数 参数 是否必选 参数类型 描述
查询单个转储任务 功能介绍 查询单个转储任务。 当前页面API为历史版本API,未来可能停止维护。请使用查询Smart Connector任务详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/connectors/{connector_i
修改自动创建Topic的配置,会触发重启吗? 开启或者关闭“Kafka自动创建Topic”,会导致Kafka重启。 父主题: Topic和分区问题
实例消费正常,为什么看不到消费者? 检查是否使用Flink进行消费。Flink使用的是assign模式,消费者定义在客户端,因此在Kafka实例控制台看不到消费者。 父主题: 消费组问题