消息队列 CKafka 版

最近更新时间:2025-09-05 01:30:29

我的收藏

消息队列 CKafka(Cloud Kafka)是基于开源 Apache Kafka 消息队列引擎,提供高吞吐性能、高可扩展性的消息队列服务。消息队列 CKafka 完美兼容 Apache kafka 0.9、0.10、1.1、2.4、2.8版本接口,在性能、扩展性、业务安全保障、运维等方面具有超强优势,让您在享受低成本、超强功能的同时,免除繁琐运维工作。

下表为操作审计支持的消息队列 CKafka 版操作列表:

操作名称 资源类型 事件名称
增加分区 ckafka AddPartition
添加路由 ckafka AddRoute
增加主题白名单 ckafka AddTopicIpwhitelist
实例授权token ckafka AuthorizeToken
批量添加 ACL 策略 ckafka BatchCreateAcl
批量修改消费组offset ckafka BatchModifyGroupOffsets
批量设置主题属性 ckafka BatchModifyTopicAttributes
取消授权token ckafka CancelAuthorizationToken
查询cdc任务接口 ckafka CheckCdcCluster
校验删除实例 ckafka CheckDelete
添加 ACL 策略 ckafka CreateAcl
添加 ACL 规则 ckafka CreateAclRule
创建cdc-ckafka集群 ckafka CreateCdcCluster
创建Datahub连接源 ckafka CreateConnectResource
创建消费者组 ckafka CreateConsumer
创建DIP转储任务 ckafka CreateDatahubTask
创建Dip主题 ckafka CreateDatahubTopic
创建按量计费实例 ckafka CreateInstancePost
创建实例(预付费包年包月) ckafka CreateInstancePre
增加主题分区 ckafka CreatePartition
创建按量计费实例(新) ckafka CreatePostPaidInstance
添加普罗米修斯监控 ckafka CreatePrometheus
添加路由 ckafka CreateRoute
批量创建限流规则 ckafka CreateThrottleRule
创建token ckafka CreateToken
创建主题 ckafka CreateTopic
创建主题IP白名单 ckafka CreateTopicIpWhiteList
添加用户 ckafka CreateUser
删除ACL ckafka DeleteAcl
删除ACL规则 ckafka DeleteAclRule
删除Datahub连接源 ckafka DeleteConnectResource
删除Dip任务 ckafka DeleteDatahubTask
删除DIP主题 ckafka DeleteDatahubTopic
删除消费组 ckafka DeleteGroup
删除后付费实例 ckafka DeleteInstancePost
删除预付费实例 ckafka DeleteInstancePre
销毁隔离中的预付费实例 ckafka DeleteIsolatedInstancePre
删除路由 ckafka DeleteRoute
修改路由触发时间 ckafka DeleteRouteTriggerTime
删除限流规则 ckafka DeleteThrottleRule
删除主题 ckafka DeleteTopic
删除主题IP白名单 ckafka DeleteTopicIpWhiteList
删除主题白名单 ckafka DeleteTopicIpwhitelist
删除用户 ckafka DeleteUser
枚举ACL ckafka DescribeACL
查询ACL规则列表 ckafka DescribeAclRule
查询用户列表 ckafka DescribeAppInfo
查询混沌演练任务执行结果 ckafka DescribeAsyncResult
查看是否可以自动创建ConsumerGroup ckafka DescribeAutoCreateConsumerGroup
查询broker数量 ckafka DescribeBrokerCount
查询broker tcp连接情况 ckafka DescribeBrokerIpTcpConnect
查询ckafka实例数概览 ckafka DescribeCkafkaOverview
查询实例版本信息 ckafka DescribeCkafkaVersion
查看可用区列表 ckafka DescribeCkafkaZone
查询Dip连接源 ckafka DescribeConnectResource
查询Dip连接源列表 ckafka DescribeConnectResources
列出消息分组 ckafka DescribeConsumerGroup
查询跨地域任务支持地域 ckafka DescribeCrossRegionSupportList
获取实例的CVM信息 ckafka DescribeCvmInfo
获取Datahub消费分组offset ckafka DescribeDatahubGroupOffsets
查询 Datahub 任务概览 ckafka DescribeDatahubOverview
查询Datahub任务信息 ckafka DescribeDatahubTask
查询Dip任务列表 ckafka DescribeDatahubTasks
获取DIP主题属性 ckafka DescribeDatahubTopic
查询DIP主题列表 ckafka DescribeDatahubTopics
查询链路列表 ckafka DescribeDipLinks
查询Dip任务事件列表 ckafka DescribeDipTaskEventLogs
查询事件中心日志详情 ckafka DescribeEventCenterLogDetail
查询事件中心日志列表 ckafka DescribeEventCenterLogs
查询日志事件 ckafka DescribeEventLog
查询标准版集群拆分任务 ckafka DescribeFederationClusterTask
获取消费分组信息 ckafka DescribeGroup
查询消费分组 ckafka DescribeGroupInfo
获取消费分组offset ckafka DescribeGroupOffsets
获取实例属性 ckafka DescribeInstanceAttributes
获取实例节点实时详情 ckafka DescribeInstanceBrokers
获取实例CVM信息 ckafka DescribeInstanceCvm
获取实例列表信息 ckafka DescribeInstances
获取实例集群列表详情 ckafka DescribeInstancesDetail
查询自建上云任务列表 ckafka DescribeMigrateToCloudTask
获取实例Prometheus信息 ckafka DescribePrometheus
查询地域 ckafka DescribeRegion
路由详情 ckafka DescribeRoute
查询自动化运维任务列表 ckafka DescribeRoutineMaintenanceTasks
查询Schema列表 ckafka DescribeSchema
查询安全组路由信息列表 ckafka DescribeSecurityGroupRoutes
查询任务状态 ckafka DescribeTaskStatus
查询实例限流规则列表 ckafka DescribeThrottleRules
获取主题列表 ckafka DescribeTopic
获取主题属性 ckafka DescribeTopicAttributes
主题列表详情 ckafka DescribeTopicDetail
查询当前实例的Topic 流量排行 ckafka DescribeTopicFlowRanking
实例所有未同步副本 ckafka DescribeTopicOutOfReplica
查询topic生产端连接信息 ckafka DescribeTopicProduceConnection
查询订阅某主题消息分组信息 ckafka DescribeTopicSubscribeGroup
获取Topic 同步副本信息 ckafka DescribeTopicSyncReplica
获取实例列表 ckafka DescribeTypeInstances
查询用户信息 ckafka DescribeUser
查询用户实例 ckafka DescribeUserInstances
查询Datahub Topic消息 ckafka FetchDatahubMessageByOffset
查询Datahub Topic最新消息列表 ckafka FetchLatestDatahubMessageList
查询消息 ckafka FetchMessageByOffset
根据位点查询消息列表 ckafka FetchMessageListByOffset
根据时间戳查询消息列表 ckafka FetchMessageListByTimestamp
获取实例属性 ckafka GetInstanceAttributes
获取主题属性 ckafka GetTopicAttributes
Ckafka实例购买/续费询价 ckafka InquireCkafkaPrice
实例缩容 ckafka InstanceScalingDown
隔离预付费实例接口 ckafka IsolatedInstancePre
列出消费分组 ckafka ListConsumerGroup
获取实例列表 ckafka ListInstance
路由详情 ckafka ListRoute
获取主题列表 ckafka ListTopic
修改Acl预设规则 ckafka ModifyAclRule
编辑Datahub连接源 ckafka ModifyConnectResource
修改Datahub任务 ckafka ModifyDatahubTask
修改Dip主题属性 ckafka ModifyDatahubTopic
ModifyGroupOffsets ckafka ModifyGroupOffsets
设置实例属性 ckafka ModifyInstanceAttributes
预付费实例变配接口,调整磁盘,带宽 ckafka ModifyInstancePre
修改密码 ckafka ModifyPassword
设置自动化运维属性 ckafka ModifyRoutineMaintenanceTask
修改实例限流规则 ckafka ModifyThrottleRule
修改主题属性 ckafka ModifyTopicAttributes
暂停流程任务 ckafka PauseWorkflow
续费Ckafka实例 ckafka RenewCkafkaInstance
重启故障区节点 ckafka RestartDisasterZone
重启流程任务 ckafka RestartWorkflow
恢复暂停的流程任务 ckafka ResumeWorkflow
重试失败的流程任务 ckafka RetryWorkflow
HTTP发送消息 ckafka SendMessage
发送消息 ckafka SendMessageByTopic
设置ckafka转发消息到cos ckafka SetForward
设置实例属性 ckafka SetInstanceAttributes
修改主题属性 ckafka SetTopicAttributes
终止流程任务 ckafka TerminateWorkflow