在运行 Java SDK 代码收发消息前,您需按照本文提供的步骤来准备开发环境。
开发环境
操作步骤
1 创建资源
接入消息队列 Kafka版收发消息前,需要先创建资源和用户。
- 在火山引擎控制台中创建 Kafka 实例。
详细操作步骤请参考创建实例。 - 创建 Topic。
每一条消息都属于一个 Topic,发送与接收消息时都需要指定交互的 Topic。详细操作步骤请参考创建 Topic。 - (可选)创建 SASL 用户和 ACL。
创建实例时需要指定 PLAIN 机制的用户名和密码,用于创建 PLAIN 类型的 SASL 用户,该用户默认具备所有 Topic 和 Group 的读写权限,您可以通过 SASL 接入点接入消息队列 Kafka版并使用 PLAIN 机制消费消息。
如果需要更细粒度的的权限控制,您也可以创建一个新的 SASL 用户,并为其添加一条 ACL,为该用户授予指定资源的指定权限。详细操作步骤请参考创建用户。说明
通过默认接入点收发消息时,无需创建 SASL 用户、通过 SASL 用户进行鉴权。
2 收集连接信息
调用相关接口类收发消息时需要在代码中配置连接信息等参数,收发消息前请参考以下步骤获取连接信息。
- 收集接入点地址。
创建实例后,您可以在实例的概览页面接入点区域中查看接入点的信息。详细说明请参考查看接入点。 - 获取 Topic 名称。
创建 Topic 后,可以在实例的Topic管理页签中查看 Topic 名称。 - (可选)获取 SASL 用户名称及密码。
创建 SASL 用户时需要指定 SASL 用户的用户名及密码,请妥善保管此信息。创建 PLAIN 用户后,可以在实例的用户管理页签中查看密码,详细操作请参考查看 PLAIN 用户密码。如果忘记了 SCRAM 用户的密码,可以重置用户密码,详细操作请参考重置 SASL 用户密码。说明
请根据客户端认证机制,使用对应类型用户的用户名及密码进行进行 SASL 认证,例如在 PLAIN 机制下应使用 PLAIN 用户的用户名及密码。详细说明请参考查看接入点。
3 (可选)下载 Demo
火山引擎消息队列 Kafka版为您提供示例项目Demo供您快速接入和体验。请下载 Demo 并解压缩到本地项目中。配置文件模板位于路径 {DemoPath}/src/main/resources/
中,您可以参考配置文件了解详细的参数配置。