检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
enable_auto_topic 是 Boolean 是否开启自动创建topic功能。 响应参数 无 请求示例 开启实例自动创建topic功能。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/autotopic {
String 实例转储ID。 请求示例 新规格按需实例的开启Smart Connect，设置Smart Connect节点数量为2。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector {
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{
请参考查询实例返回的数据。 task_id 是 String 转储任务ID。 请求参数 无 响应参数 无 请求示例 删除指定的转储任务。 DELETE https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}
String 维护时间窗结束时间。 begin String 维护时间窗开始时间。 seq Integer 序号。 请求示例 GET https://{endpoint}/v2/instances/maintain-windows 响应示例 状态码： 200 查询成功。 { "maintain_windows"
查看Kafka实例后台任务 对实例的一些操作，如表1所示，会启动一个后台任务，您可以在后台任务页，查看该操作的状态等信息，同时可通过删除操作，清理任务信息。 表1 后台任务列表 任务名 说明 创建实例 创建一个Kafka实例。 重启实例 重启Kafka实例。 Kafka配置参数修改
Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?offest=
broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers
权限类型。 all：拥有发布、订阅权限; pub：拥有发布权限; sub：拥有订阅权限。 请求示例 查询Topic的用户权限。 GET https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy
描述 id String Topic名称。 success Boolean 是否删除成功。 请求示例 批量删除Topic。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/delete
users 否 Array of strings 用户列表。 当删除用户时，为必选参数。 响应参数 无 请求示例 批量删除用户。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "action"
report_id String 诊断报告ID。 请求示例 创建消费组group-test，主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
error_code String 错误码。 error_msg String 错误描述。 请求示例 编辑一个消费组，消费组描述为desc。 PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/groups/test
是否为默认可用区。 remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 GET https://{endpoint}/v2/available-zones 响应示例 状态码： 200 查询可用区信息成功。 查询实例成功返回示例如下。
@#$%^&*()-_=+\|[{}];:'",<.>/? 和空格，并且不能以-开头。 响应参数 无 请求示例 重置Kafka Manager的密码。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/kafka-manager-password
result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager
default_app Boolean 是否为默认应用。 created_time Long 创建时间。 请求示例 查询用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users 响应示例 状态码：
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
