消息队列 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 |
解析ClickHouse的Schema | ckafka | AnalyseClickHouseSchema |
数据解析 | ckafka | AnalyseContent |
解析消息的 Schema | ckafka | AnalyseRecordSchema |
绑定路由安全组 | 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 |
校验Datahub转储任务 | ckafka | CheckCreateDatahubTask |
校验删除实例 | ckafka | CheckDelete |
CreateAcl | ckafka | CreateAcl |
添加 ACL 规则 | ckafka | CreateAclRule |
创建cdc-ckafka集群 | ckafka | CreateCdcCluster |
创建Dip连接源 | ckafka | CreateConnectResource |
创建数据同步任务 | ckafka | CreateConnector |
创建消费者组 | ckafka | CreateConsumer |
创建跨地域同步任务 | ckafka | CreateCrossRegionSyncTask |
创建Datahub消费者组 | ckafka | CreateDatahubGroup |
创建Dip转储任务 | ckafka | CreateDatahubTask |
创建Dip主题 | ckafka | CreateDatahubTopic |
创建链路 | ckafka | CreateDipLink |
创建实例前置校验 | ckafka | CreateInstance |
创建一键诊断任务 | ckafka | CreateInstanceAnalysis |
创建后付费实例接口 | ckafka | CreateInstancePost |
创建实例(预付费包年包月) | ckafka | CreateInstancePre |
创建迁移上云任务 | ckafka | CreateMigrateToCloudTask |
增加分区 | ckafka | CreatePartition |
创建按量计费实例(新) | ckafka | CreatePostPaidInstance |
添加普罗米修斯监控 | ckafka | CreatePrometheus |
添加路由 | ckafka | CreateRoute |
创建Schema | ckafka | CreateSchema |
生成当前输入字符串的正则表达式模式串 | ckafka | CreateStringRegularExpressionMatchPattern |
创建,变更系统维护时间 | ckafka | CreateSystemMaintenanceTime |
创建token | ckafka | CreateToken |
创建主题 | ckafka | CreateTopic |
增加主题白名单 | ckafka | CreateTopicIpWhiteList |
添加用户 | ckafka | CreateUser |
混沌演练生产消费延迟 | ckafka | DelayMessage |
混沌演练生产消费延迟恢复 | ckafka | DelayMessageRollback |
DeleteAcl | ckafka | DeleteAcl |
删除ACL规则 | ckafka | DeleteAclRule |
删除Dip连接源 | ckafka | DeleteConnectResource |
删除Connector | ckafka | DeleteConnector |
删除跨地域同步任务 | ckafka | DeleteCrossRegionSyncTask |
删除Datahub消费组 | ckafka | DeleteDatahubGroup |
删除Dip任务 | ckafka | DeleteDatahubTask |
删除Dip主题 | ckafka | DeleteDatahubTopic |
删除链路 | ckafka | DeleteDipLink |
删除消费组 | ckafka | DeleteGroup |
删除消费分组订阅的topic | ckafka | DeleteGroupSubscribeTopic |
删除实例前置校验 | ckafka | DeleteInstance |
删除后付费实例 | ckafka | DeleteInstancePost |
删除预付费实例 | ckafka | DeleteInstancePre |
销毁Prometheus监控 | ckafka | DeletePrometheus |
删除路由 | ckafka | DeleteRoute |
修改路由触发时间 | ckafka | DeleteRouteTriggerTime |
删除Schema | ckafka | DeleteSchema |
删除主题 | ckafka | DeleteTopic |
删除主题IP白名单 | ckafka | DeleteTopicIpWhiteList |
删除主题白名单 | ckafka | DeleteTopicIpwhitelist |
DeleteUser | ckafka | DeleteUser |
枚举ACL | ckafka | DescribeACL |
查询ACL规则列表 | ckafka | DescribeAclRule |
查询一键诊断报告详细 | ckafka | DescribeAnalysisDetail |
一键诊断概览 | ckafka | DescribeAnalysisDistribute |
查询是否大客户 | ckafka | DescribeAppIdIsVip |
查询用户列表 | ckafka | DescribeAppInfo |
查询混沌演练任务执行结果 | ckafka | DescribeAsyncResult |
混沌演练关机结果查询 | ckafka | DescribeAttackAsyncRequestResult |
查看是否可以自动创建ConsumerGroup | ckafka | DescribeAutoCreateConsumerGroup |
查询broker数量 | ckafka | DescribeBrokerCount |
查询broker的ip信息 | ckafka | DescribeBrokerIpInfo |
查询broker tcp连接情况 | ckafka | DescribeBrokerIpTcpConnect |
查询ckafka实例数概览 | ckafka | DescribeCkafkaOverview |
询价 | ckafka | DescribeCkafkaPrice |
评估ckafka规格 | ckafka | DescribeCkafkaSpecifications |
获取实例规格配置 | ckafka | DescribeCkafkaTypeConfigs |
查询实例版本信息 | ckafka | DescribeCkafkaVersion |
查询可用区 | ckafka | DescribeCkafkaZone |
查询Dip连接源 | ckafka | DescribeConnectResource |
查询Dip连接源列表 | ckafka | DescribeConnectResources |
获取同步任务列表 | ckafka | DescribeConnector |
差选Connector配置 | ckafka | DescribeConnectorConfigs |
查询Connector 状态 | ckafka | DescribeConnectorStatus |
列出消息分组 | ckafka | DescribeConsumerGroup |
跨地容灾任务的connector信息列表 | ckafka | DescribeCrossRegionConnectorTasks |
查询跨地域同步任务操作状态 | ckafka | DescribeCrossRegionFlowStatus |
查询跨地域任务支持地域 | ckafka | DescribeCrossRegionSupportList |
查询跨地域同步任务详情 | ckafka | DescribeCrossRegionSyncTaskAttributes |
查询跨地域同步任务列表 | ckafka | DescribeCrossRegionSyncTasks |
获取实例CVM信息 | ckafka | DescribeCvmInfo |
查询跨地域同步任务数据同步进度 | ckafka | DescribeDataSyncProgress |
查询订阅Datahub主题的消息分组信息 | ckafka | DescribeDatahubGroup |
获取Datahub消费分组offset | ckafka | DescribeDatahubGroupOffsets |
查询 Datahub 任务概览 | ckafka | DescribeDatahubOverview |
查询Dip任务信息 | ckafka | DescribeDatahubTask |
查询Dip任务列表 | ckafka | DescribeDatahubTasks |
获取Dip主题属性 | ckafka | DescribeDatahubTopic |
查询Dip主题列表 | ckafka | DescribeDatahubTopics |
查询链路详情 | ckafka | DescribeDipLinkAttributes |
查询链路列表 | ckafka | DescribeDipLinks |
查询Dip任务事件列表 | ckafka | DescribeDipTaskEventLogs |
查询Dip任务元数据同步进度 | ckafka | DescribeDipTaskSyncMetadataProgress |
查询事件中心日志详情 | ckafka | DescribeEventCenterLogDetail |
查询事件中心日志列表 | ckafka | DescribeEventCenterLogs |
查询日志事件 | ckafka | DescribeEventLog |
获取消费分组信息 | ckafka | DescribeGroup |
查询消费分组 | ckafka | DescribeGroupInfo |
获取消费分组offset | ckafka | DescribeGroupOffsets |
查询 HTTP 接入任务 | ckafka | DescribeHttpSourceTask |
查询实例是否社区版 | ckafka | DescribeIfCommunity |
获取实例列表数据 | ckafka | DescribeInstance |
获取实例属性 | ckafka | DescribeInstanceAttributes |
获取实例CVM信息 | ckafka | DescribeInstanceCvm |
获取实例列表详情 | ckafka | DescribeInstanceDetail |
获取实例硬盘容量变动记录列表 | ckafka | DescribeInstanceDiskChangeHistory |
获取实例列表 | ckafka | DescribeInstances |
获取实例列表 | ckafka | DescribeInstancesDetail |
云监控获取实例列表 | ckafka | DescribeInstancesMonitor |
云监控获取实例和机器列表 | ckafka | DescribeInstancesMonitorDetail |
查询跨地域同步任务元数据同步进度 | ckafka | DescribeMetaDataSyncProgress |
查询自建上云任务列表 | ckafka | DescribeMigrateToCloudTask |
查询事件中心均衡任务详情 | ckafka | DescribeMigrationTask |
查询变配类型 | ckafka | DescribeModifyType |
新版询价接口 | ckafka | DescribeOrderConfig |
获取实例Prometheus信息 | ckafka | DescribePrometheus |
查询地域 | ckafka | DescribeRegion |
混沌演练开机结果查询 | ckafka | DescribeRollbackAsyncRequestResult |
路由详情 | ckafka | DescribeRoute |
查询自动化运维任务列表 | ckafka | DescribeRoutineMaintenanceTasks |
查询正在变配中的事件 | ckafka | DescribeRunningEventIds |
查询Schema列表 | ckafka | DescribeSchema |
查询Schema详情 | ckafka | DescribeSchemaAttributes |
查询安全组路由列表 | ckafka | DescribeSecurityGroupRoutes |
拉取连接服务的具体存储单元 | ckafka | DescribeTargetResource |
查询任务状态 | ckafka | DescribeTaskStatus |
获取主题列表 | ckafka | DescribeTopic |
获取主题属性 | ckafka | DescribeTopicAttributes |
主题列表详情 | ckafka | DescribeTopicDetail |
获取主题的磁盘占用量 | ckafka | DescribeTopicDiskUsage |
查询topic节点分布情况 | ckafka | DescribeTopicDistribute |
查询当前实例的Topic 流量排行 | ckafka | DescribeTopicFlowRanking |
实例所有未同步副本 | ckafka | DescribeTopicOutOfReplica |
查询topic生产端连接信息 | ckafka | DescribeTopicProduceConnection |
查询订阅某主题消息分组信息 | ckafka | DescribeTopicSubscribeGroup |
获取Topic 同步副本信息 | ckafka | DescribeTopicSyncReplica |
获取实例列表 | ckafka | DescribeTypeInstances |
查询用户信息 | ckafka | DescribeUser |
查询用户实例 | ckafka | DescribeUserInstances |
解绑路由安全组 | ckafka | DisassociateRoutesSecurityGroup |
混沌演练开机 | ckafka | DownAttackRollback |
查询Datahub Topic消息 | ckafka | FetchDatahubMessageByOffset |
拉取连接器任务最后的消息 | ckafka | FetchLatestDatahubMessageList |
查询最新消息列表 | ckafka | FetchLatestMessageList |
查询消息 | ckafka | FetchMessageByOffset |
根据位点查询消息列表 | ckafka | FetchMessageListByOffset |
根据时间戳查询消息列表 | ckafka | FetchMessageListByTimestamp |
获取实例属性 | ckafka | GetInstanceAttributes |
获取主题属性 | ckafka | GetTopicAttributes |
混沌演练关机 | ckafka | InjectDownAttack |
Ckafka实例购买/续费询价 | ckafka | InquireCkafkaPrice |
实例缩容 | ckafka | InstanceScalingDown |
销毁资源 | ckafka | IsolateResource |
列出消费分组 | ckafka | ListConsumerGroup |
获取实例列表 | ckafka | ListInstance |
路由详情 | ckafka | ListRoute |
获取主题列表 | ckafka | ListTopic |
修改Acl预设规则 | ckafka | ModifyAclRule |
编辑Dip连接源 | ckafka | ModifyConnectResource |
设置是否可以自动创建consumerGroup | ckafka | ModifyConsumerGroupConfig |
设置Datahub Groups 消费分组offset | ckafka | ModifyDatahubGroupOffsets |
增加Dip主题分区 | ckafka | ModifyDatahubPartition |
修改dip主题密码 | ckafka | ModifyDatahubPassword |
修改Datahub数据源配置 | ckafka | ModifyDatahubResource |
修改Datahub任务 | ckafka | ModifyDatahubTask |
修改Dip主题属性 | ckafka | ModifyDatahubTopic |
设置ckafka消息转发到cos | ckafka | ModifyForward |
ModifyGroupOffsets | ckafka | ModifyGroupOffsets |
实例变配前置校验 | ckafka | ModifyInstance |
设置实例属性 | ckafka | ModifyInstanceAttributes |
设置跨可用区集群 | ckafka | ModifyInstanceMultiZone |
预付费实例变配接口,调整磁盘,带宽 | ckafka | ModifyInstancePre |
修改实例账号信息 | ckafka | ModifyInstancesOwner |
ModifyPassword | ckafka | ModifyPassword |
修改路由安全组关联 | ckafka | ModifyRouteSecurityGroups |
设置动态消息保留策略 | ckafka | ModifyRoutineMaintenanceTask |
修改Schema | ckafka | ModifySchema |
修改主题属性 | ckafka | ModifyTopicAttributes |
修改数据处理规则 | ckafka | ModifyTransformation |
暂停数据同步任务 | ckafka | PauseConnector |
暂停跨地域同步任务 | ckafka | PauseCrossRegionSyncTask |
暂停Dip任务 | ckafka | PauseDatahubTask |
续费Ckafka实例 | ckafka | RenewCkafkaInstance |
续费实例 | ckafka | RenewInstance |
退订公网带宽 | ckafka | ResetPublicNetwork |
重启Datahub任务 | ckafka | RestartDatahubTask |
启动Connector任务 | ckafka | ResumeConnector |
恢复跨地域同步任务 | ckafka | ResumeCrossRegionSyncTask |
恢复Dip任务 | ckafka | ResumeDatahubTask |
HTTP 数据上报 | ckafka | SendMessage |
DIP Topic发送消息 | ckafka | SendMessageByDatahubTopic |
发送消息 | ckafka | SendMessageByTopic |
设置ckafka转发消息到cos | ckafka | SetForward |
设置实例属性 | ckafka | SetInstanceAttributes |
修改主题属性 | ckafka | SetTopicAttributes |
数据处理 | ckafka | TransformContent |
解绑Schema | ckafka | UnbindSchema |
broker版本升级接口 | ckafka | UpgradeBrokerVersion |