检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Go 本文以Linux CentOS环境为例，介绍Go 1.16.5版本的Kafka客户端连接指导，包括demo代码库的获取，以及生产、消费消息。 使用前请参考收集连接信息收集Kafka所需的连接信息。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
查看Kafka生产消费示例代码 分布式消息服务Kafka版支持在控制台查看Java、Go和Python语言的生产消费消息示例代码，您可以参考示例代码快速完成Kafka客户端的集成，并进行消息的生产和消费。 查看Kafka生产消费示例代码 登录管理控制台。 在管理控制台左上角单击，选择区域。
概述 Kafka实例完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果“kafka安全协议”设置为“SASL_SSL”，则在开源客户端基础上使用云服务提供的证书文件。 本指南主要介绍实例连接信息的收集，如获取实例连接地址、Topic名称等，然后提供Java、Python和Go等语言的连接示例。
Kafka连接问题排查和解决 概述 本章节主要描述Kafka连接问题的排查和解决。 问题分类 当您发现与Kafka实例连接出现异常时，可以根据本文的内容，从以下几个方面进行排查。 检查网络 检查Consumer和Producer的配置 客户端连接问题-Java客户端 客户端连接问题-Go客户端
Redis实例类型。（仅目标端类型为Redis时会显示） dcs_instance_id String DCS实例ID。（仅目标端类型为Redis时会显示） target_db Integer 目标数据库，默认为-1。（仅目标端类型为Redis时会显示） consumer_strategy String 转储启动
"params" : "{\"public_ip_id\":\"1aea7aed-e7d8-40ea-b3de-6f3ee9d5db9f\",\"public_ip_address\":\"100.93.2.18\",\"enable_public_ip\":true}"
Redis实例类型。（仅目标端类型为Redis时会显示） dcs_instance_id String DCS实例ID。（仅目标端类型为Redis时会显示） target_db Integer 目标数据库，默认为-1。（仅目标端类型为Redis时会显示） consumer_strategy String 转储启动
Redis实例类型。（仅目标端类型为Redis时会显示） dcs_instance_id String DCS实例ID。（仅目标端类型为Redis时会显示） target_db Integer 目标数据库，默认为-1。（仅目标端类型为Redis时会显示） consumer_strategy String 转储启动
为什么不建议使用Sarama客户端收发消息？ 问题现象 使用Sarama客户端收发消息存在以下问题： Sarama客户端无法感知分区变化，当Topic分区数增加时，需要重启客户端后才能正常消费。 Sarama客户端消息最大处理时间（MaxProcessingTime）默认值为10
SDK概述 本文介绍了分布式消息服务Kafka版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。
暂停Smart Connect任务 功能介绍 暂停Smart Connect任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause 表1
查询项目标签 功能介绍 查询项目标签。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/tags 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 请求参数
删除单个转储任务 功能介绍 删除单个转储任务。 当前页面API为历史版本API，未来可能停止维护。请使用删除Smart Connector任务。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/connectors/{connector_
查询维护时间窗时间段 功能介绍 查询维护时间窗开始时间和结束时间。 调用方法 请参见如何调用API。 URI GET /v2/instances/maintain-windows 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 maintain_windows
删除后台任务管理中的指定记录 功能介绍 删除后台任务管理中的指定记录。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/tasks/{task_id} 表1 路径参数 参数 是否必选 参数类型
关闭Smart Connect（按需实例） 功能介绍 介绍按需实例如何关闭Smart Connect。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/delete-connector
查询转储任务列表 功能介绍 查询转储任务列表。 当前页面API为历史版本API，未来可能停止维护。请使用查询Smart Connect任务列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/connectors/{connector_id}/sink-tasks
启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 功能介绍 用于启动未启动的Smart Connect任务以及重启已暂停或者运行中的Smart Connect任务。注意，重启Smart Connect任务将重置同步进度，并重新开始同步任务。
启动已暂停的Smart Connect任务 功能介绍 启动已暂停的Smart Connect任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume
开启或关闭实例自动创建topic功能 功能介绍 开启或关闭实例自动创建topic功能。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/autotopic 表1 路径参数 参数 是否必选 参数类型
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
