-
创建消费组 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
创建用户 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
编辑消费组 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
getenv("CLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = KafkaClient.new_builder() \ .with_credentials(credentials) \
-
修改实例信息 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
修改Kafka实例Topic - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
查询转储任务列表 - 分布式消息服务Kafka版
getenv("CLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = KafkaClient.new_builder() \ .with_credentials(credentials) \
-
删除后台任务管理中的指定记录 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
关闭Smart Connect(按需实例) - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
查询项目标签 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
暂停Smart Connect任务 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
启动已暂停的Smart Connect任务 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
是可用的,副本数越大可靠性越高。 该参数设置为1时,表示只有一份数据。 说明: 实例节点出现故障的情况下,单副本Topic查询消息时可能会报“内部服务错误”,因此不建议使用单副本Topic。 3 老化时间(小时) 消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。
-
实例扩容 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
查询单个转储任务 - 分布式消息服务Kafka版
getenv("CLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = KafkaClient.new_builder() \ .with_credentials(credentials) \
-
重置密码 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
查询用户列表 - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)
-
查看Kafka审计日志 - 分布式消息服务Kafka版
事件名称 创建DMS实例订单成功 kafka createDMSInstanceOrderSuccess 创建DMS实例任务执行成功 kafka createDMSInstanceTaskSuccess 创建DMS实例订单失败 kafka createDMSInstanceOrderFailure
-
Kafka实例查询Topic - 分布式消息服务Kafka版
"{project_id}" credentials = BasicCredentials(ak, sk, projectId) \ client = KafkaClient.new_builder() \ .with_credentials(credentials)