消息队列 Kafka版
消息队列 Kafka版
文档指南
请输入
- 文档首页
消息队列 Kafka版SDK 参考Apache Kafka SDKJava 客户端 SDK准备工作
复制全文
下载 pdf准备工作
文档反馈
问问助手在运行 Java SDK 代码收发消息前，您需按照本文提供的步骤来准备开发环境。
开发环境
注意事项
JDK版本大于等于21时，则需要Kafka SDK版本>4.0.0，原因为JDK 21后javax.security.auth.Subject#getSubject已经不在支持，会导致SASL认证场景下客户端初始化认证逻辑失败。
操作步骤
1 创建资源
接入消息队列 Kafka版收发消息前，需要先创建资源和用户。
- 在火山引擎控制台中创建 Kafka 实例。
- 详细操作步骤请参考创建实例。
- 创建 Topic。
- 每一条消息都属于一个 Topic，发送与接收消息时都需要指定交互的 Topic。详细操作步骤请参考创建 Topic。
- （可选）创建 SASL 用户和 ACL。
- 创建实例时需要指定 PLAIN 机制的用户名和密码，用于创建 PLAIN 类型的 SASL 用户，该用户默认具备所有 Topic 和 Group 的读写权限，您可以通过 SASL 接入点接入消息队列 Kafka版并使用 PLAIN 机制消费消息。
- 如果需要更细粒度的的权限控制，您也可以创建一个新的 SASL 用户，并为其添加一条 ACL，为该用户授予指定资源的指定权限。详细操作步骤请参考创建用户。
说明
通过 PLAINTEXT 接入点收发消息时，无需创建 SASL 用户、通过 SASL 用户进行鉴权。
2 收集连接信息
调用相关接口类收发消息时需要在代码中配置连接信息等参数，收发消息前请参考以下步骤获取连接信息。
- 收集接入点地址。
- 创建实例后，您可以在实例的概览页面接入点区域中查看接入点的信息。详细说明请参考查看接入点。
- 获取 Topic 名称。
- 创建 Topic 后，可以在实例的Topic管理页签中查看 Topic 名称。
- （可选）获取 SASL 用户名称及密码。
- 创建 SASL 用户时需要指定 SASL 用户的用户名及密码，请妥善保管此信息。创建 PLAIN 用户后，可以在实例的用户管理页签中查看密码，详细操作请参考查看 PLAIN 用户密码。如果忘记了 SCRAM 用户的密码，可以重置用户密码，详细操作请参考重置 SASL 用户密码。
说明
3 （可选）下载 Demo
火山引擎消息队列 Kafka版为您提供示例项目Demo供您快速接入和体验。请下载 Demo 并解压缩到本地项目中。配置文件模板位于路径 {DemoPath}/src/main/resources/ 中，您可以参考配置文件了解详细的参数配置。
最近更新时间：2026.01.07 17:03:59
这个页面对您有帮助吗？
有用
有用
无用
无用