CLI命令参考
生命周期管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 创建Kafka实例 | hcloud Kafka CreatePostPaidKafkaInstance | 创建实例。 | |
| 查询所有实例列表 | hcloud Kafka ListInstances | 查询租户的实例列表,支持按照条件查询。 | |
| 查询指定实例 | hcloud Kafka ShowInstance | 查询指定实例的详细信息。 | |
| 删除指定的实例 | hcloud Kafka DeleteInstance | 删除指定的实例,释放该实例的所有资源。 | |
| 修改实例信息 | hcloud Kafka UpdateInstance | 修改实例信息。 | |
| 批量重启或删除实例 | hcloud Kafka BatchRestartOrDeleteInstances | 批量重启或删除实例。 | |
| 获取实例配置 | hcloud Kafka ShowInstanceConfigs | 获取实例配置。 | |
| 修改实例配置 | hcloud Kafka ModifyInstanceConfigs | 修改实例配置。 | |
| 实例升级 | hcloud Kafka UpgradeInstance | 实例内核升级。 | |
| 查询Kafka实例版本信息 | hcloud Kafka ShowUpgradeInstanceVersion | 查询Kafka实例版本信息。 |
实例管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 重置密码 | hcloud Kafka ResetPassword | 重置密码(只针对开通SSL的实例)。 | |
| 重置Manager密码 | hcloud Kafka ResetManagerPassword | 重置Manager密码。 | |
| 重启Manager | hcloud Kafka RestartManager | 重启Manager。 | |
| 修改实例跨VPC访问的内网IP | hcloud Kafka UpdateInstanceCrossVpcIp | 修改实例跨VPC访问的内网IP。 | |
| 查询Kafka集群元数据信息 | hcloud Kafka ShowCluster | 查询Kafka集群元数据信息。 | |
| 查询Kafka实例的协调器信息 | hcloud Kafka ShowCoordinators | 查询Kafka实例的协调器信息。 | |
| 修改Kafka的接入方式 | hcloud Kafka UpdateKafkaPortProtocol | 修改Kafka的内网或者公网接入方式。 | |
| 查询Topic的磁盘存储情况 | hcloud Kafka ShowKafkaTopicPartitionDiskusage | 查询Topic在Broker上磁盘占用情况。 | |
| 恢复回收站实例 | hcloud Kafka RestoreRecycleInstance | 恢复回收站实例。 | |
| 查询回收站实例列表 | hcloud Kafka ShowRecycleInstances | 查询回收站实例列表。 | |
| 更新回收站策略 | hcloud Kafka ModifyRecyclePolicy | 更新回收站策略。 | |
| 关闭Kafka Manager | hcloud Kafka CloseKafkaManager | 关闭Kafka Manager,相应的原来开放出的management相关接口也将不可用。 | |
| 查询Kafka实例重平衡日志详情 | hcloud Kafka ShowKafkaRebalanceLog | 查询Kafka实例重平衡日志详情。 | |
| 开启Kafka实例重平衡日志功能 | hcloud Kafka CreateKafkaRebalanceLogTask | 开启Kafka实例重平衡日志功能。 | |
| 关闭Kafka实例重平衡日志功能 | hcloud Kafka StopKafkaRebalanceLogTask | 关闭Kafka实例重平衡日志功能。 | |
| 开启或者关闭Kafka实例公网访问功能 | hcloud Kafka ModifyKafkaPublicIpAccessSwitch | 开启或者关闭Kafka实例公网访问功能。 | |
| 查询Kafka集群信息 | hcloud Kafka ShowKafkaCluster | 查询Kafka集群信息。 |
Smart Connect
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 查询开启Smart Connect功能所需资源信息 | hcloud Kafka ShowConnectorResourceInfo | 查询开启Smart Connect功能所需要使用的资源的情况 | |
| 开启Smart Connect(按需实例) | hcloud Kafka CreateConnector | 开启Smart Connect,提交创建Smart Connect节点任务。 | |
| 关闭Smart Connect(按需实例) | hcloud Kafka DeleteConnector | 介绍按需实例如何关闭Smart Connect。 | |
| 创建Smart Connect任务 | hcloud Kafka CreateConnectorTask | 创建Smart Connect任务。 | |
| 查询Smart Connect任务列表 | hcloud Kafka ListConnectorTasks | 查询Smart Connect任务列表。 | |
| 查询Smart Connect任务详情 | hcloud Kafka ShowConnectorTask | 查询Smart Connect任务详情。 | |
| 删除Smart Connect任务 | hcloud Kafka DeleteConnectorTask | 删除Smart Connect任务。 | |
| 修改Smart Connect任务配置 | hcloud Kafka ModifyConnectorTask | 修改Smart Connect任务配置。 | |
| 校验Connector连通性 | hcloud Kafka ValidateConnectorConnectivity | 校验Connector连通性。 | |
| 暂停Smart Connect任务 | hcloud Kafka PauseConnectorTask | 暂停Smart Connect任务。 | |
| 启动已暂停的Smart Connect任务 | hcloud Kafka ResumeConnectorTask | 启动已暂停的Smart Connect任务。 | |
| 启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 | hcloud Kafka RestartConnectorTask | 用于启动未启动的Smart Connect任务以及重启已暂停或者运行中的Smart Connect任务。注意,重启Smart Connect任务将重置同步进度,并重新开始同步任务。 | |
| 查询OBS桶列表 | hcloud Kafka ListObsBuckets | 查询OBS桶列表。 |
规格变更管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 实例扩容 | hcloud Kafka ResizeKafkaInstance | 实例规格变更。当前通过调用API,只支持按需实例进行实例扩容。 | |
| 查询实例的扩容规格列表 | hcloud Kafka ShowKafkaInstanceExtendProductInfo | 查询实例的扩容规格列表。 | |
| 查询磁盘自动扩容配置 | hcloud Kafka ShowVolumeExpandConfig | 查询磁盘自动扩容配置,包括磁盘自动扩容是否开启,以及开启后的扩容阈值、扩容步长、扩容上限信息。 | |
| 修改磁盘自动扩容配置 | hcloud Kafka UpdateVolumeExpansionConfig | 该接口用于修改磁盘自动扩容配置,包含磁盘自动扩容是否开启、扩容阈值、扩容步长,以及扩容上限的配置。 | |
| 获取Kafka实例扩容前置检查信息 | hcloud Kafka ShowKafkaScalePreCheckInfo | 获取Kafka实例扩容前置检查信息。 |
主题管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 开启或关闭实例自动创建Topic功能 | hcloud Kafka UpdateInstanceAutoCreateTopic | 开启或关闭实例自动创建Topic功能。 | |
| Kafka生产消息 | hcloud Kafka SendKafkaMessage | 在控制台发送指定消息到Kafka实例。 | |
| Kafka实例创建Topic | hcloud Kafka CreateInstanceTopic | 该接口用于向Kafka实例创建Topic。 | |
| Kafka实例查询Topic | hcloud Kafka ListInstanceTopics | 该接口用于查询指定Kafka实例的Topic详情。 | |
| 修改Kafka实例Topic | hcloud Kafka UpdateInstanceTopic | 修改Kafka实例Topic | |
| 获取Kafka Topic详细信息 | hcloud Kafka ShowKafkaTopicDetail | 获取Kafka Topic详细信息。 | |
| Kafka实例批量删除Topic | hcloud Kafka BatchDeleteInstanceTopic | 该接口用于向Kafka实例批量删除Topic。批量删除多个Topic时,部分删除成功,部分失败,此时接口返回删除成功,并在返回中显示删除失败的Topic信息。 | |
| 查询Topic的分区列表 | hcloud Kafka ListTopicPartitions | 查询Topic的分区列表。 | |
| 查询Topic的当前生产者列表 | hcloud Kafka ListTopicProducers | 查询Topic的当前生产者列表。 | |
| 删除Topic流控配置 | hcloud Kafka DeleteKafkaTopicQuota | 该接口用于向Kafka实例提交删除Topic级别的流控任务,若成功则返回流控任务的job_id。 | |
| 创建Topic流控配置 | hcloud Kafka CreateKafkaTopicQuota | 该接口用于向Kafka实例提交创建Topic级别的流控任务,若成功则返回流控任务的job_id。 | |
| 修改Topic流控配置 | hcloud Kafka ModifyKafkaTopicQuota | 该接口用于向Kafka实例提交修改Topic级别的流控任务,若成功则返回流控任务的job_id。 | |
| 查询Topic流控配置 | hcloud Kafka ShowKafkaTopicQuota | 该接口用于查询Topic级别的流控任务。 | |
| Kafka实例开始分区平衡任务 | hcloud Kafka CreateKafkaReassignmentTask | 该接口用于向Kafka实例提交分区平衡任务,若成功则返回分区平衡任务的job id。 |
消费组管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 查询消费组信息 | hcloud Kafka ShowGroups | 查询消费组信息。 | |
| 重置消费组消费进度到指定位置 | hcloud Kafka ResetMessageOffsetWithEngine | Kafka实例不支持在线重置消费进度。在执行重置消费进度之前,必须停止被重置消费组客户端。 | |
| 查询所有消费组 | hcloud Kafka ListInstanceConsumerGroups | 查询所有消费组。 | |
| Kafka实例批量删除消费组 | hcloud Kafka BatchDeleteGroup | 该接口用于向Kafka实例批量删除消费组。 | |
| 创建消费组 | hcloud Kafka CreateKafkaConsumerGroup | 实例创建消费组。 | |
| 查询消费组消息位点 | hcloud Kafka ListInstanceConsumerGroupMessageOffset | 查询消费组消息位点。 | |
| 修改所有消费组 | hcloud Kafka UpdateInstanceGroup | 修改所有消费组。 | |
| 查询指定消费组 | hcloud Kafka ListInstanceConsumerGroup | 查询指定消费组。 | |
| 删除指定消费组 | hcloud Kafka DeleteInstanceConsumerGroup | 删除指定消费组。 | |
| 修改指定消费组 | hcloud Kafka UpdateInstanceConsumerGroup | 修改指定消费组。 | |
| 查询指定消费组的Topic | hcloud Kafka ListInstanceConsumerGroupTopics | 查询指定消费组的Topic。 | |
| 删除消费组在指定Topic的消费位点 | hcloud Kafka DeleteConsumerGroupOffsets | 删除消费组在指定Topic的消费位点。 | |
| 查询指定消费组的消费成员 | hcloud Kafka ListInstanceConsumerGroupMembers | 查询指定消费组的消费成员。 |
用户管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 删除用户/客户端流控配置 | hcloud Kafka DeleteKafkaUserClientQuotaTask | 该接口用于向Kafka实例提交删除用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 | |
| 查询用户/客户端流控配置 | hcloud Kafka ShowKafkaUserClientQuota | 该接口用于向Kafka实例查询流控的配置,若成功则返回流控配置的列表。 | |
| 创建用户/客户端流控配置 | hcloud Kafka CreateKafkaUserClientQuotaTask | 该接口用于向Kafka实例提交创建用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 | |
| 修改用户/客户端流控配置 | hcloud Kafka UpdateKafkaUserClientQuotaTask | 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 | |
| 查询用户列表 | hcloud Kafka ShowInstanceUsers | 查询用户列表。 | |
| 创建用户 | hcloud Kafka CreateInstanceUser | 创建Kafka实例的用户,用户可连接开启SASL的Kafka实例。 2023年7月15日前创建的Kafka实例,一个实例最多创建20个用户。2023年7月15日及以后创建的Kafka实例,一个实例最多创建500个用户。 | |
| 批量删除用户 | hcloud Kafka BatchDeleteInstanceUsers | 批量删除Kafka实例的用户。 | |
| 重置用户密码 | hcloud Kafka ResetUserPasswrod | 重置用户密码 | |
| 修改用户参数 | hcloud Kafka UpdateInstanceUser | 修改用户参数 | |
| 查询用户权限 | hcloud Kafka ShowTopicAccessPolicy | 查询用户权限。 | |
| 设置用户权限 | hcloud Kafka UpdateTopicAccessPolicy | 设置用户权限。 |
消息管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 查询消息 | hcloud Kafka ShowInstanceMessages | Kafka实例查询消息。 | |
| 查询分区指定偏移量的消息 | hcloud Kafka ShowPartitionMessage | 查询分区指定偏移量的消息。 | |
| 查询分区指定时间段的消息 | hcloud Kafka ShowMessages | 查询分区指定时间段的消息。 | |
| 查询分区最早消息的位置 | hcloud Kafka ShowPartitionBeginningMessage | 查询分区最早消息的位置。 | |
| 查询分区最新消息的位置 | hcloud Kafka ShowPartitionEndMessage | 查询分区最新消息的位置。 | |
| 删除Kafka消息 | hcloud Kafka DeleteKafkaTopicMessages | 删除Kafka消息。 |
后台任务管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 查询实例的后台任务列表 | hcloud Kafka ListBackgroundTasks | 查询实例的后台任务列表。 | |
| 查询后台任务管理中的指定记录 | hcloud Kafka ShowBackgroundTask | 查询后台任务管理中的指定记录。 | |
| 删除后台任务管理中的指定记录 | hcloud Kafka DeleteBackgroundTask | 删除后台任务管理中的指定记录。 | |
| 查询实例的定时任务列表 | hcloud Kafka ListScheduledTasks | 查询实例的定时任务列表。 | |
| 查询后台任务中的指定实例的变更进度 | hcloud Kafka ShowBackgroundTaskProgress | 查询后台任务中的指定实例的变更进度。 | |
| 删除指定的定时任务 | hcloud Kafka DeleteScheduledTask | 删除指定的定时任务。仅当定时任务处于执行成功或已取消状态时,方可执行删除操作。 | |
| 修改指定的定时任务 | hcloud Kafka UpdateScheduledTask | 修改指定的定时任务。 |
标签管理
诊断管理
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 消息积压诊断预检查 | hcloud Kafka ShowDiagnosisPreCheck | 消息积压诊断预检查。 | |
| 创建消息积压诊断任务 | hcloud Kafka CreateMessageDiagnosisTask | 创建消息积压诊断任务。 | |
| 查询消息积压诊断报告列表 | hcloud Kafka ListMessageDiagnosisReports | 查询消息积压诊断报告列表。 | |
| 批量删除消息积压诊断报告 | hcloud Kafka BatchDeleteMessageDiagnosisReports | 批量删除消息积压诊断报告。 | |
| 查询诊断报告详情 | hcloud Kafka ShowMessageDiagnosisReport | 查询诊断报告详情。 |
其他接口
| API名称 | 命令 | 描述 | 操作 |
|---|---|---|---|
| 查询维护时间窗时间段 | hcloud Kafka ShowMaintainWindows | 查询维护时间窗开始时间和结束时间。 | |
| 查询可用区信息 | hcloud Kafka ListAvailableZones | 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 | |
| 查询产品规格列表 | hcloud Kafka ListEngineProducts | 查询产品规格列表。 | |
| 查询实例在CES的监控层级关系 | hcloud Kafka ShowCesHierarchy | 查询实例在CES的监控层级关系。 | |
| 查询Kafka产品规格核数 | hcloud Kafka ShowKafkaProductCores | 查询Kafka产品规格核数。 | |
| 查询特性开关列表 | hcloud Kafka ListConfigFeatures | 获取特性开关列表。 |