检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class SendKafkaMessageSolution {
*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class UpdateTopicReplicaSolution
M管理员可以为不同职能部门的员工按照最小权限原则授予不同的数据访问权限，详情请参见权限管理。 建议配置安全组访问控制，保护您的数据不被异常读取和操作。 租户配置安全组的入方向、出方向规则限制，可以控制连接实例的网络范围，避免DMS for Kafka暴露给不可信第三方，详情请参见
*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateInstanceTopicSolution
购买完成ECS后，需要在ECS中完成以下配置： 安装Java JDK，并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1.8.0_231 export PATH=$JAVA_HOME/bin:$PATH 下载Kafka命令行工具2
String kv_delimiter，默认为":"。（仅目标端类型为OBS时会显示） 请求示例 创建一个立即启动的转储任务。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks
*; import com.huaweicloud.sdk.kafka.v2.model.*; import java.util.List; import java.util.ArrayList; public class UpdateInstanceTopicSolution
描述 error_code String 错误码。 error_msg String 错误描述。 请求示例 查询消息偏移量。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages?asc=f
配置类型：dynamic/static value String 配置值 value_type String 配置值类型 请求示例 查询Topic列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics?offset=0&limit=10
配置类型：static/dynamic。 value String 配置当前值。 value_type String 值类型。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs 响应示例 状态码：200
200 表3 响应Body参数 参数 参数类型 描述 order_id String 返回cbc生成的订单id。 请求示例 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/delete-connector-order
删除后台任务管理中的指定记录。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2
请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go
请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go
TagMultyValueEntity 参数 参数类型 描述 key String 标签键。 values Array of strings 标签值。 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码：200 查询项目标签成功。 { "tags"
String 维护时间窗结束时间。 begin String 维护时间窗开始时间。 seq Integer 序号。 请求示例 GET https://{endpoint}/v2/instances/maintain-windows 响应示例 状态码：200 查询成功。 { "maintain_windows"
删除指定的转储任务。 DELETE https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 1
修改转储任务的配额。 PUT https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks { "sink_max_tasks" : 9 } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python
响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1
请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
