概述
更新时间：2026-09-09
本文介绍如何使用消息服务 for Kafka Java SDK 管理 Kafka 资源，入口类为 com.baidubce.services.kafka.KafkaClient。
Java SDK 支持的资源包括：
- 集群管理
- 集群配置管理
- 主题管理
- 消费组管理
- 用户管理
- 权限管理
- 任务管理
- Quota 管理
Java SDK 用于调用 Kafka OpenAPI，不用于连接 Kafka 集群生产或消费消息。集群内的消息收发请使用 Apache Kafka 官方客户端。 请求与响应模型位于
com.baidubce.services.kafka.model下，按业务域分包：
| 包 | 内容 |
|---|---|
model.cluster |
集群创建、变更、启停、访问配置、Controller、节点 |
model.config |
集群配置与配置版本 |
model.topic |
主题、分区、订阅关系、消息收发与查询 |
model.consumer |
消费组、订阅主题、位点重置 |
model.user |
集群用户与密码 |
model.acl |
ACL 授权 |
model.job |
任务与操作 |
model.quota |
生产/消费限流 |
评价此篇文章