检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
面。 在左侧导航栏选择“回收站”，进入“回收站”页面。 通过以下任意一种方法，恢复Kafka实例。 勾选Kafka实例名称左侧的方框，可选一个或多个，单击信息栏左上侧的“恢复”。 在待恢复Kafka实例所在行，单击“恢复”。 在弹出的“恢复实例”对话框中，单击“确定”。 恢复实例
增加编译复杂度。由于导入C++库，Golang编译器需要引入额外编译配置，增加了编译依赖，提高编译复杂度。 Kafka-go kafka-go是一个简单、轻量级的Kafka客户端库，易于学习和使用。 kafka-go的代码库相对较小，依赖较少，可以减少应用程序的体积和依赖关系。 Kaf
、受影响的分区或者broker，以及解决消息堆积的建议。 前提条件 已创建Kafka实例，并且消费组正在以非assign方式消费消息中。 一个消费组正在诊断中时，无法对其他消费组进行诊断，也无法对此消费组消费的其他Topic进行诊断。 操作流程 图1 消息积压诊断流程图 步骤一：诊断前检查
的资源已在回收站中，单击操作列的“删除”，彻底删除此资源。 按需计费资源删除后，可能还会存在账单信息，因为系统通常会在使用后1个小时内对上一个结算周期的费用进行扣款。例如在8:30删除按小时结算的Kafka实例，但是8:00~9:00期间产生的费用，通常会在10:00左右才进行扣费。
hName=false 响应消息 响应参数 参数说明见表2。 表2 参数说明 参数 类型 说明 instances Array 实例的详情数组。 instance_num Integer 实例个数。 表3 instance参数说明 参数 类型 说明 name String 实例名称。
API签名指南。 签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。 Token认证 Token的有效期为24小时，需要使用一个Token鉴权时，可以先缓存起来，避免频繁调用。 Token在计算机系统中代表令牌（临时）的意思，拥有Token就代表拥有某种权限。Tok
d}/sink-tasks { "sink_max_tasks" : 9 } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 修改转储任务的配额。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
/kafka/instances/{instance_id}/management 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
s/{instance_id}/connector/tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
明文接入方法如表4所示。 表4 关闭明文接入方法 接入方式 关闭明文接入 内网访问明文接入 内网访问不支持关闭，明文接入和密文接入至少开启一个。如果密文接入没有开启，此时无法关闭明文接入。 在“内网访问 > 明文接入”后，单击，弹出确认对话框。 单击“确认”，跳转到“后台任务管理
6, "begin" : "18", "end" : "22" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
ctors/{connector_id}/sink-tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
}/instances/{instance_id}/tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
tance_id}/connector/tasks/{task_id}/pause 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
ance_id}/connector/tasks/{task_id}/resume 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
"key" : "key2", "values" : [ "value2" ] } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
} 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 brokers：实例连接地址与端口。 group：消费组名称。根据业务需求，自定义消费组名称，如果设置的消费组不存在，Kafka会自动创建。 topics：Topic名称。 user/password：首次开启密文接入时
no.acl.found”设置为“true”，且Topic未授权任何用户，此时所有的用户都可以订阅/发布此Topic。如果Topic已授权某一个或多个用户，此时只有授权的用户可以订阅/发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if
单击“确定”，完成Smart Connect任务的删除。 启动/暂停Smart Connect任务 暂停任务后，Kafka实例的数据将不会再同步到另一个Kafka实例或者其他云服务中。 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
