消息队列 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 |
| 绑定路由安全组 | ckafka | AssociateRoutesSecurityGroup |
| 实例授权token | ckafka | AuthorizeToken |
| 批量添加ACL策略 | ckafka | BatchCreateAcl |
| 批量删除ACL | ckafka | BatchDeleteAcl |
| 批量修改消费组offset | ckafka | BatchModifyGroupOffsets |
| 批量设置主题属性 | ckafka | BatchModifyTopicAttributes |
| 绑定Schema | ckafka | BindSchema |
| 混沌演练CPU高负载 | ckafka | BurnCPU |
| 混沌演练磁盘高负载 | ckafka | BurnDiskIO |
| 取消授权token | ckafka | CancelAuthorizationToken |
| 查询cdc任务接口 | ckafka | CheckCdcCluster |
| CreateAcl | ckafka | CreateAcl |
| 添加 ACL 规则 | ckafka | CreateAclRule |
| 创建cdc-ckafka集群 | ckafka | CreateCdcCluster |
| 创建连接器连接 | ckafka | CreateConnectResource |
| 创建数据同步任务 | ckafka | CreateConnector |
| 创建消费者组 | ckafka | CreateConsumer |
| 创建跨地域同步任务 | ckafka | CreateCrossRegionSyncTask |
| 创建Datahub消费者组 | ckafka | CreateDatahubGroup |
| 创建连接器任务 | ckafka | CreateDatahubTask |
| 创建Dip主题 | ckafka | CreateDatahubTopic |
| 创建链路 | ckafka | CreateDipLink |
| 创建实例前置校验 | ckafka | CreateInstance |
| 创建一键诊断任务 | ckafka | CreateInstanceAnalysis |
| 创建实例(预付费包年包月) | ckafka | CreateInstancePre |
| 创建迁移上云任务 | ckafka | CreateMigrateToCloudTask |
| 增加分区 | ckafka | CreatePartition |
| 创建按量计费实例（新） | ckafka | CreatePostPaidInstance |
| 添加普罗米修斯监控 | ckafka | CreatePrometheus |
| 添加路由 | ckafka | CreateRoute |
| 创建Schema | ckafka | CreateSchema |
| 生成当前输入字符串的正则表达式模式串 | ckafka | CreateStringRegularExpressionMatchPattern |
| 创建，变更系统维护时间 | ckafka | CreateSystemMaintenanceTime |
| 批量创建限流规则 | ckafka | CreateThrottleRule |
| 创建token | ckafka | CreateToken |
| 创建主题 | ckafka | CreateTopic |
| 增加主题白名单 | ckafka | CreateTopicIpWhiteList |
| 添加用户 | ckafka | CreateUser |
| 混沌演练生产消费延迟 | ckafka | DelayMessage |
| 混沌演练生产消费延迟恢复 | ckafka | DelayMessageRollback |
| DeleteAcl | ckafka | DeleteAcl |
| 删除ACL规则 | ckafka | DeleteAclRule |
| 删除连接器连接 | ckafka | DeleteConnectResource |
| 删除Connector | ckafka | DeleteConnector |
| 删除跨地域同步任务 | ckafka | DeleteCrossRegionSyncTask |
| 删除Datahub消费组 | ckafka | DeleteDatahubGroup |
| 删除连接器任务 | ckafka | DeleteDatahubTask |
| 删除Dip主题 | ckafka | DeleteDatahubTopic |
| 删除链路 | ckafka | DeleteDipLink |
| 删除消费组 | ckafka | DeleteGroup |
| 删除消费分组订阅的topic | ckafka | DeleteGroupSubscribeTopic |
| 删除实例前置校验 | ckafka | DeleteInstance |
| 删除后付费实例 | ckafka | DeleteInstancePost |
| 删除预付费实例 | ckafka | DeleteInstancePre |
| 销毁隔离中的预付费实例 | ckafka | DeleteIsolatedInstancePre |
| 销毁Prometheus监控 | ckafka | DeletePrometheus |
| 删除路由 | ckafka | DeleteRoute |
| 修改路由触发时间 | ckafka | DeleteRouteTriggerTime |
| 删除Schema | ckafka | DeleteSchema |
| 删除限流规则 | ckafka | DeleteThrottleRule |
| 删除主题 | ckafka | DeleteTopic |
| 删除主题IP白名单 | ckafka | DeleteTopicIpWhiteList |
| DeleteUser | ckafka | DeleteUser |
| 枚举ACL | ckafka | DescribeACL |
| 查询ACL规则列表 | ckafka | DescribeAclRule |
| 查询用户列表 | ckafka | DescribeAppInfo |
| 查询混沌演练任务执行结果 | ckafka | DescribeAsyncResult |
| 查询ckafka实例数概览 | ckafka | DescribeCkafkaOverview |
| 查看可用区列表 | ckafka | DescribeCkafkaZone |
| 查询连接器连接详情 | ckafka | DescribeConnectResource |
| 查询连接器连接列表 | ckafka | DescribeConnectResources |
| 查询消费分组信息 | ckafka | DescribeConsumerGroup |
| 获取实例的CVM信息 | ckafka | DescribeCvmInfo |
| 获取Datahub消费分组offset | ckafka | DescribeDatahubGroupOffsets |
| 查询连接器任务详情 | ckafka | DescribeDatahubTask |
| 查询连接器任务列表 | ckafka | DescribeDatahubTasks |
| 获取DIP主题属性 | ckafka | DescribeDatahubTopic |
| 查询DIP主题列表 | ckafka | DescribeDatahubTopics |
| 查询Dip任务元数据同步进度 | ckafka | DescribeDipTaskSyncMetadataProgress |
| 查询标准版集群拆分任务 | ckafka | DescribeFederationClusterTask |
| 枚举消费分组(精简版) | ckafka | DescribeGroup |
| 获取消费分组信息 | ckafka | DescribeGroupInfo |
| 获取消费分组offset | ckafka | DescribeGroupOffsets |
| 获取实例属性 | ckafka | DescribeInstanceAttributes |
| 获取实例节点实时详情 | ckafka | DescribeInstanceBrokers |
| 获取实例列表信息 | ckafka | DescribeInstances |
| 获取实例列表 | ckafka | DescribeInstancesDetail |
| 查询变配类型 | ckafka | DescribeModifyType |
| 新版询价接口 | ckafka | DescribeOrderConfig |
| 获取实例Prometheus信息 | ckafka | DescribePrometheus |
| 枚举地域 | ckafka | DescribeRegion |
| 查看路由信息 | ckafka | DescribeRoute |
| 查询安全组路由信息列表 | ckafka | DescribeSecurityGroupRoutes |
| 查询任务状态 | ckafka | DescribeTaskStatus |
| 获取主题列表 | ckafka | DescribeTopic |
| 获取主题属性 | ckafka | DescribeTopicAttributes |
| 获取主题列表详情 | ckafka | DescribeTopicDetail |
| Topic 流量排行 | ckafka | DescribeTopicFlowRanking |
| 查询topic生产端连接信息 | ckafka | DescribeTopicProduceConnection |
| 查询订阅某主题消息分组信息 | ckafka | DescribeTopicSubscribeGroup |
| 获取Topic 同步副本信息 | ckafka | DescribeTopicSyncReplica |
| 获取实例列表 | ckafka | DescribeTypeInstances |
| 根据实例id查询用户信息 | ckafka | DescribeUser |
| 查询用户实例 | ckafka | DescribeUserInstances |
| 解绑路由安全组 | ckafka | DisassociateRoutesSecurityGroup |
| 混沌演练开机 | ckafka | DownAttackRollback |
| 查询Datahub Topic消息 | ckafka | FetchDatahubMessageByOffset |
| 拉取连接器任务最后的消息 | ckafka | FetchLatestDatahubMessageList |
| 查询消息 | ckafka | FetchMessageByOffset |
| 根据位点查询消息列表 | ckafka | FetchMessageListByOffset |
| 根据时间戳查询消息列表 | ckafka | FetchMessageListByTimestamp |
| 获取实例属性 | ckafka | GetInstanceAttributes |
| 获取主题属性 | ckafka | GetTopicAttributes |
| 混沌演练关机 | ckafka | InjectDownAttack |
| Ckafka询价 | ckafka | InquireCkafkaPrice |
| 实例缩容 | ckafka | InstanceScalingDown |
| 隔离预付费实例接口 | ckafka | IsolatedInstancePre |
| 列出消费分组 | ckafka | ListConsumerGroup |
| 获取实例列表 | ckafka | ListInstance |
| 路由详情 | ckafka | ListRoute |
| 获取主题列表 | ckafka | ListTopic |
| 修改Acl预设规则 | ckafka | ModifyAclRule |
| 编辑连接器连接 | ckafka | ModifyConnectResource |
| 设置是否可以自动创建consumerGroup | ckafka | ModifyConsumerGroupConfig |
| 设置Datahub Groups 消费分组offset | ckafka | ModifyDatahubGroupOffsets |
| 增加Dip主题分区 | ckafka | ModifyDatahubPartition |
| 修改dip主题密码 | ckafka | ModifyDatahubPassword |
| 修改Datahub数据源配置 | ckafka | ModifyDatahubResource |
| 修改连接器任务 | ckafka | ModifyDatahubTask |
| 修改Dip主题属性 | ckafka | ModifyDatahubTopic |
| 设置ckafka消息转发到cos | ckafka | ModifyForward |
| ModifyGroupOffsets | ckafka | ModifyGroupOffsets |
| 设置实例属性 | ckafka | ModifyInstanceAttributes |
| 设置跨可用区集群 | ckafka | ModifyInstanceMultiZone |
| 预付费实例变配接口，调整磁盘，带宽 | ckafka | ModifyInstancePre |
| ModifyPassword | ckafka | ModifyPassword |
| 修改路由安全组关联 | ckafka | ModifyRouteSecurityGroups |
| 设置动态消息保留策略 | ckafka | ModifyRoutineMaintenanceTask |
| 修改Schema | ckafka | ModifySchema |
| 修改实例限流规则 | ckafka | ModifyThrottleRule |
| 修改主题属性 | ckafka | ModifyTopicAttributes |
| 修改topic副本数 | ckafka | ModifyTopicReplicas |
| 修改数据处理规则 | ckafka | ModifyTransformation |
| 暂停数据同步任务 | ckafka | PauseConnector |
| 暂停跨地域同步任务 | ckafka | PauseCrossRegionSyncTask |
| 暂停连接器任务 | ckafka | PauseDatahubTask |
| 续费Ckafka实例 | ckafka | RenewCkafkaInstance |
| 退订公网带宽 | ckafka | ResetPublicNetwork |
| 重启连接器任务 | ckafka | RestartDatahubTask |
| 重启故障区节点 | ckafka | RestartDisasterZone |
| 启动Connector任务 | ckafka | ResumeConnector |
| 恢复跨地域同步任务 | ckafka | ResumeCrossRegionSyncTask |
| 恢复连接器任务 | ckafka | ResumeDatahubTask |
| HTTP 数据上报 | ckafka | SendMessage |
| DIP Topic发送消息 | ckafka | SendMessageByDatahubTopic |
| 发送消息 | ckafka | SendMessageByTopic |
| 设置ckafka转发消息到cos | ckafka | SetForward |
| 设置实例属性 | ckafka | SetInstanceAttributes |
| 修改主题属性 | ckafka | SetTopicAttributes |
| 容灾主动切换ckafka可用区broker的接口 | ckafka | SwitchAvailableZone |
| 解绑Schema | ckafka | UnbindSchema |
| broker版本升级接口 | ckafka | UpgradeBrokerVersion |
