接口列表

更新时间：2026-09-09

KafkaClient 共提供 78 个 public 接口方法，其中 listUsers(String) 与 listAcls(String) 是便捷重载，去重后为 76 个业务接口。

方法	说明
`createCluster`	创建集群
`deleteCluster`	释放集群
`listClusters`	查询集群列表
`getClusterDetail`	查询集群详情
`getClusterDeletion`	查询集群删除详情
`getClusterAccessEndpoints`	查询集群接入点
`getClusterNodes`	查询集群节点列表
`getClusterConfigurations`	查询集群当前配置项
`increaseBrokerCount`	增加节点数量
`decreaseBrokerCount`	减少节点数量
`migrateClusterAz`	迁移集群可用区
`unifyClusterEndpoint`	统一集群访问地址
`updateBrokerNodeType`	变更节点机型
`expandBrokerDiskCapacity`	扩容磁盘容量
`updateAccessConfig`	变更访问与认证配置
`startCluster`	启动集群
`stopCluster`	停止集群
`resizeClusterEipBandwidth`	变更公网带宽
`switchClusterEip`	开启或关闭公网访问
`updateStoragePolicy`	变更磁盘阈值策略
`updateKafkaConfig`	应用集群配置版本
`updateSecurityGroup`	变更安全组
`updateMaintenanceDuration`	变更可维护时间
`switchClusterIntranetIp`	开启或关闭产品间转储
`getClusterCurrentController`	查询当前 Controller
`getClusterHistoryController`	查询历史 Controller
`restartCluster`	重启集群
`restartBroker`	重启指定 Broker
`switchClusterAdvertisedIp`	开启或关闭跨 VPC 访问
`switchClusterDomain`	开启或关闭集群域名
`getZkPassword`	查询 ZooKeeper 访问凭证

方法	说明
`createClusterConfig`	创建集群配置
`listClusterConfigs`	查询集群配置列表
`deleteClusterConfig`	删除集群配置
`getClusterConfig`	查询集群配置详情
`createClusterConfigRevision`	新增集群配置版本
`listClusterConfigRevisions`	查询集群配置版本列表
`getClusterConfigRevision`	查询集群配置版本详情

方法	说明
`createTopic`	创建主题
`deleteTopic`	删除主题
`listTopic`	查询主题列表
`getTopicDetail`	查询主题详情
`updateTopic`	变更主题分区数或配置
`listTopicPartitions`	查询主题分区列表
`getTopicPartitionDetail`	查询主题分区详情
`getTopicPartitionOverview`	查询主题分区概览
`listSubscribedGroups`	查询订阅主题的消费组
`getSubscribedGroupDetail`	查询主题订阅详情
`getSubscribedGroupOverview`	查询主题订阅关系概览
`listTopicConfigOptions`	查询主题支持的参数信息
`sendTopicMessage`	向主题发送消息
`queryTopicMessagesByStartTime`	按起始时间查询消息
`queryTopicMessagesByStartOffset`	按起始位点查询消息

方法	说明
`listConsumerGroup`	查询消费组列表
`deleteConsumerGroup`	删除消费组
`resetConsumerGroup`	重置消费组位点
`listSubscribedTopics`	查询消费组订阅的主题列表
`getSubscribedTopicOverview`	查询消费组订阅关系概览

评价此篇文章

有帮助没帮助

百度智能云