You need to enable JavaScript to run this app.
导航

准备工作

最近更新时间2023.09.12 17:32:18

首次发布时间2022.01.28 15:16:00

在运行 Go SDK 代码收发消息前,您需按照本文提供的步骤来准备开发环境。

开发环境

开发环境中需要安装 1.13.0 及以上版本的 Go。详细说明请参考 Go 官方文档

操作步骤

1 创建资源

接入消息队列 Kafka版收发消息前,需要先创建资源和用户。

  1. 在火山引擎控制台中创建 Kafka 实例。
    详细操作步骤请参考创建实例
  2. 创建 Topic。
    每一条消息都属于一个 Topic,发送与接收消息时都需要指定交互的 Topic。详细操作步骤请参考创建 Topic
  3. (可选)创建 SASL 用户和 ACL。
    创建实例时需要指定 PLAIN 机制的用户名和密码,用于创建 PLAIN 类型的 SASL 用户,该用户默认具备所有 Topic 和 Group 的读写权限,您可以通过 SASL 接入点接入消息队列 Kafka版并使用 PLAIN 机制消费消息。
    如果需要更细粒度的的权限控制,您也可以创建一个新的 SASL 用户,并为其添加一条 ACL,为该用户授予指定资源的指定权限。详细操作步骤请参考创建用户

    说明

    通过默认接入点收发消息时,无需创建 SASL 用户、通过 SASL 用户进行鉴权。

2 收集连接信息

调用相关接口类收发消息时需要在代码中配置连接信息等参数,收发消息前请参考以下步骤获取连接信息。

  1. 收集接入点地址。
    创建实例后,您可以在实例的概览页面接入点区域中查看接入点的信息。详细说明请参考查看接入点
  2. 获取 Topic 名称。
    创建 Topic 后,可以在实例的Topic管理页签中查看 Topic 名称。
  3. (可选)获取 SASL 用户名称及密码。
    创建 SASL 用户时需要指定 SASL 用户的用户名及密码,请妥善保管此信息。创建 PLAIN 用户后,可以在实例的用户管理页签中查看密码,详细操作请参考查看 PLAIN 用户密码。如果忘记了 SCRAM 用户的密码,可以重置用户密码,详细操作请参考重置 SASL 用户密码

    说明

    请根据客户端认证机制,使用对应类型用户的用户名及密码进行进行 SASL 认证,例如在 PLAIN 机制下应使用 PLAIN 用户的用户名及密码。详细说明请参考查看接入点

3 (可选)下载 Demo

火山引擎消息队列 Kafka版为您提供示例项目 Demo 供您快速接入和体验。请下载 Demo 并解压缩到本地项目中。配置文件位于路径 {DemoPath}/config/config_templete.json中,您可以参考SDK 配置说明了解详细的参数配置。