-
配置Kafka流控 - 分布式消息服务Kafka版
在页面左上角单击“创建流控”,弹出“创建流控”对话框。 设置流控参数。 表1 流控参数说明 参数名称 说明 用户名 输入指定用户名,对此用户进行流控。如果需要对所有用户进行流控,在“用户名”后,单击“选择默认”。 流控创建完后,无法修改“用户名”。 客户端ID 输入指定客户端ID,对此客户端进行流
-
Kafka Manager如何修改Topic的分区Leader? - 分布式消息服务Kafka版
单击待修改分区Leader的Topic名称(以topic-test为例介绍),进入Topic详情页面。 单击“Manual Partition Assignments”,进入修改分区Leader页面。 图1 Topic详情页面 图2 修改分区Leader页面 以修改分区2的Leader为例介绍(Replica 0
-
删除Kafka消息 - 分布式消息服务Kafka版
消息删除 表1 消息删除参数说明 参数 说明 分区 选择消息所在的分区编号。 偏移量 输入偏移量,此偏移量之前的数据将被删除。 说明: 如果“偏移量”设置为“-1”,表示删除分区中所有的消息。 如果您输入的偏移量不在指定分区的最早偏移量和最晚偏移量之间,消息将不会被删除。 如果需要删除
-
使用客户端连接Kafka(明文接入) - 分布式消息服务Kafka版
opic名称。 本文以公网连接为例,获取的Kafka实例公网连接地址为“10.xx.xx.45:9094,10.xx.xx.127:9094,10.xx.xx.103:9094”。执行完命令后输入内容,按“Enter”发送消息到Kafka实例,输入的每一行内容都将作为一条消息发送到Kafka实例。
-
Kafka是否支持Kerberos认证,如何开启认证? - 分布式消息服务Kafka版
Kafka是否支持Kerberos认证,如何开启认证? Kafka支持SASL客户端认证、调用接口支持Token和AK/SK两种认证,Kerberos认证目前不支持。 如果使用SASL认证方式,则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。具体操作参考连接开启SASL的Kafka实例。
-
配置Kafka用户 - 分布式消息服务Kafka版
> 用户名”后,单击“重置密码”,弹出“重置Kafka密码”对话框。 单击Kafka实例名称,进入实例详情页面。在“用户管理”页面,在待重置密码的用户所在行,单击“重置密码”,弹出“重置密码”对话框。 输入“新密码”,单击“确定”,完成密码重置。 如果重置密码成功,界面提示重置实例的密码成功。
-
修订记录 - 分布式消息服务Kafka版
新增诊断管理相关接口。 2024-03-06 本次变更如下: 新增Smart Connect相关接口。 将转储相关接口移动至历史API。 2024-02-26 本次变更如下: 新增生产消息接口。 2023-11-10 本次变更如下: 新增获取实例配置和修改实例配置接口。 2023-07-26
-
使用控制台连接Kafka - 分布式消息服务Kafka版
在待生产消息的Topic所在行,单击“更多 > 生产消息”,弹出“生产消息”对话框。 参考表1,设置消息的相关参数。 表1 消息参数 参数名称 说明 消息内容 输入消息的内容。 消息Key 输入消息的Key。 发送到指定分区 选择是否开启消息发送到指定的分区。 关闭:消息基于Key的hash值选择分区。
-
Kafka实例创建Topic - 分布式消息服务Kafka版
请求示例 创建一个Topic,Topic名称为test01。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "id" : "test01", "partition" : 3
-
创建转储任务 - 分布式消息服务Kafka版
200 表4 响应Body参数 参数 参数类型 描述 task_id String 任务ID。 请求示例 创建一个转储任务,转储topic-test中的数据到OBS。 POST https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks
-
关闭Kafka Manager - 分布式消息服务Kafka版
关闭Kafka Manager 功能介绍 关闭Kafka Manager,相应的原来开放出的management相关接口也将不可用。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/kafka/instances/{instance_id}/management
-
权限和授权项 - 分布式消息服务Kafka版
户权限等接口。 消息查询,包括消息查询接口对应的授权项,如查询消息接口。 后台任务管理,包括实例的后台任务管理接口对应的授权项,如查询实例的后台任务列表、查询后台任务管理中的指定记录等接口。 标签管理,包括实例的标签管理接口对应的授权项,如查询实例标签、查询项目标签等接口。 其他:包括开启关闭公网访问接口。
-
创建用户/客户端流控配置 - 分布式消息服务Kafka版
创建用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交创建用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI POST /v2/kafka/{project_id}/instances/{instance_id}
-
删除用户/客户端流控配置 - 分布式消息服务Kafka版
删除用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交删除用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI DELETE /v2/kafka/{project_id}/instances/{instance_i
-
Kafka实例查询Topic - 分布式消息服务Kafka版
Kafka实例查询Topic 功能介绍 该接口用于查询指定Kafka实例的Topic详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述
-
Kafka实例批量删除消费组 - 分布式消息服务Kafka版
"failed_groups" : [ { "group_id" : "test-1", "error_message" : "UNKNOW" }, { "group_id" : "test-2", "error_message" : "UNKNOW"
-
Kafka实例开始分区重平衡任务 - 分布式消息服务Kafka版
Kafka实例开始分区重平衡任务 功能介绍 该接口用于向Kafka实例提交分区重平衡任务或计算重平衡预估时间。 调用方法 请参见如何调用API。 URI POST /v2/kafka/{project_id}/instances/{instance_id}/reassign 表1
-
API V1 - 分布式消息服务Kafka版
API V1 实例管理类接口 实例使用类接口 其他接口 父主题: 历史API
-
修改用户/客户端流控配置 - 分布式消息服务Kafka版
修改用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_id}/instances/{instance_id}/
-
创建实例 - 分布式消息服务Kafka版
创建实例 功能介绍 创建实例。 该接口支持创建按需和包周期两种计费方式的实例。 调用方法 请参见如何调用API。 URI POST /v2/{engine}/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String