检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
build() try: request = CreateInstanceUserRequest() request.instance_id = "{instance_id}" request.body = CreateInstanceUserReq(
ShowMessagesRequest request = new ShowMessagesRequest(); request.withInstanceId("{instance_id}"); request.withTopic("{topic}");
build(); SendKafkaMessageRequest request = new SendKafkaMessageRequest(); request.withInstanceId("{instance_id}");
L证书”对话框。 图2 连接信息 参考表1，设置替换SSL证书的参数。 图3 替换SSL证书 表1 替换SSL证书参数说明 参数名称 说明 Key密码 输入制作证书中设置的keystore密码 Keystore密码 输入制作证书中设置的keystore密码 Keystore文件 导入“server
fromValue("BLOB")); request.withBody(body); try { CreateSinkTaskResponse response = client.createSinkTask(request);
request = ShowCoordinatorsRequest() request.instance_id = "{instance_id}" response = client.show_coordinators(request)
request = ShowKafkaTagsRequest() request.instance_id = "{instance_id}" response = client.show_kafka_tags(request)
request.withBody(body); try { UpdateSinkTaskQuotaResponse response = client.updateSinkTaskQuota(request);
BatchCreateOrDeleteKafkaTagRequest request = new BatchCreateOrDeleteKafkaTagRequest(); request.withInstanceId("{instance_id}");
request = RestartManagerRequest() request.instance_id = "{instance_id}" response = client.restart_manager(request)
request := &model.ShowInstanceUsersRequest{} request.InstanceId = "{instance_id}" response, err := client.ShowInstanceUsers(request) if
request = DeleteConnectorRequest() request.instance_id = "{instance_id}" response = client.delete_connector(request)
ListInstanceConsumerGroupsRequest request = new ListInstanceConsumerGroupsRequest(); request.withInstanceId("{instance_id}");
build(); ShowDiagnosisPreCheckRequest request = new ShowDiagnosisPreCheckRequest(); request.withInstanceId("{instance_id}");
REGION>")) \ .build() try: request = CreateDeleteConnectorOrderRequest() request.body = ConnectorOrderRequestBody(
查询所有实例列表 查询指定实例 删除指定的实例 修改实例信息 批量重启或删除实例 获取实例配置 修改实例配置 实例升级 开启Kafka实例域名访问能力 父主题： API V2（推荐）
3，重试间隔retry.backoff.ms=1000。 request.timeout.ms 30000 结合实际业务调整 设置一个请求最大等待时间（单位为ms），超过这个时间则会抛Timeout异常。 超时时间如果设置大一些，如127000（127秒），高并发的场景中，能减少发送失败的情况。
ListMessageDiagnosisReportsRequest request = new ListMessageDiagnosisReportsRequest(); request.withInstanceId("{instance_id}");
build(); ListBackgroundTasksRequest request = new ListBackgroundTasksRequest(); request.withInstanceId("{instance_id}");
ShowConnectorTaskRequest request = new ShowConnectorTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
