检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接Kafka网络要求 客户端可以通过公网连接Kafka实例，也可以通过内网连接Kafka实例。使用内网连接时，注意以下几点： 如果客户端和Kafka实例部署在同一个VPC内，网络默认互通。 如果客户端和Kafka实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和Kafka实例不能直接通信
请求示例 GET https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics 响应消息 响应参数 参数说明见表2。 表2 参数说明 参数 类型 说明 total Integer topic总数。
DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。
请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause 响应示例 无 SDK代码示例 SDK代码示例如下。
请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume 响应示例 无 SDK代码示例 SDK代码示例如下。
请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码： 200 查询项目标签成功。
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset { "topic" : "test", "partition
请求示例 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/delete-connector 响应示例 状态码： 200 提交关闭Smart Connect任务成功。
GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks 响应示例 状态码： 200 查询转储任务列表成功。
请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/connector/tasks/{task_id}/restart 响应示例 无 SDK代码示例 SDK代码示例如下
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/autotopic { "enable_auto_topic" : true } 响应示例 无 SDK代码示例 SDK代码示例如下。
查看Kafka实例后台任务 对实例的一些操作，如表1所示，会启动一个后台任务，您可以在后台任务页，查看该操作的状态等信息，同时可通过删除操作，清理任务信息。 表1 后台任务列表 任务名 说明 创建实例 创建一个Kafka实例。 重启实例 重启Kafka实例。 Kafka配置参数修改
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/delete { "topics" : [ "topic01" ] } 响应示例 状态码： 200 删除成功。
PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "action" : "delete", "users" : [ "testuser" ] } 响应示例 无 SDK代码示例 SDK
请求示例 创建消费组group-test，主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks {
PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/groups/test { "group_name" : "test", "group_desc" : "desc" } 响应示例 无
与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项
请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic}/messages 响应示例 状态码： 200 查询分区指定时间段的消息成功。
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/crossvpc/modify { "advertised_ip_contents" : { "192.168.245.246" : "192.168.245.247
DELETE https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota { "user" : "", "client" : "", "user-default
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
