概述
更新时间：2026-09-09
本文介绍如何使用消息服务 for Kafka Go SDK 管理 Kafka 资源，入口类型为 github.com/baidubce/bce-sdk-go/services/kafka 包中的 Client。
Go SDK 支持的资源包括：
- 集群管理
- 集群配置管理
- 主题管理
- 消费组管理
- 用户管理
- 权限管理
- 任务管理
- Quota 管理
Go SDK 用于调用 Kafka OpenAPI，不用于连接 Kafka 集群生产或消费消息。集群内的消息收发请使用 Kafka 官方客户端库。 全部请求与响应类型集中在
kafka单个包内，按文件划分职责：
| 文件 | 内容 |
|---|---|
client.go |
Client 定义与三种构造函数 |
config.go |
KafkaClientConfiguration，bce.BceClientConfiguration 的类型别名 |
kafka.go |
全部 76 个接口方法、参数校验与密码加密 |
model.go |
请求与响应结构体、命名字符串常量、自定义 JSON 序列化 |
评价此篇文章