检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
request.withBody(body); try { UpdateSinkTaskQuotaResponse response = client.updateSinkTaskQuota(request);
request := &model.CloseKafkaManagerRequest{} request.InstanceId = "{instance_id}" response, err := client.CloseKafkaManager(request) if
request = DeleteInstanceRequest() request.instance_id = "{instance_id}" response = client.delete_instance(request)
BatchDeleteMessageDiagnosisReportsRequest request = new BatchDeleteMessageDiagnosisReportsRequest(); request.withInstanceId("{instance_id}");
ShowGroupsRequest request = new ShowGroupsRequest(); request.withInstanceId("{instance_id}"); request.withGroup("{group}");
ShowInstanceTopicDetailRequest request = new ShowInstanceTopicDetailRequest(); request.withInstanceId("{instance_id}"); request.withTopic("{topic}");
REGION>")) \ .build() try: request = BatchRestartOrDeleteInstancesRequest() request.body = BatchRestartOrDeleteInstanceReq(
build(); ShowDiagnosisPreCheckRequest request = new ShowDiagnosisPreCheckRequest(); request.withInstanceId("{instance_id}");
L证书”对话框。 图2 连接信息 参考表1,设置替换SSL证书的参数。 图3 替换SSL证书 表1 替换SSL证书参数说明 参数名称 说明 Key密码 输入制作证书中设置的keystore密码 Keystore密码 输入制作证书中设置的keystore密码 Keystore文件 导入“server
build(); SendKafkaMessageRequest request = new SendKafkaMessageRequest(); request.withInstanceId("{instance_id}");
REGION>")) \ .build() try: request = CreateDeleteConnectorOrderRequest() request.body = ConnectorOrderRequestBody(
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)
password=dms@kafka #ssl.endpoint.identification.algorithm为证书域名校验开关,为空则表示关闭,这里需要保持关闭状态,必须设置为空。 ssl.endpoint.identification.algorithm= #添加ssl.truststore
build(); ListBackgroundTasksRequest request = new ListBackgroundTasksRequest(); request.withInstanceId("{instance_id}");
ListMessageDiagnosisReportsRequest request = new ListMessageDiagnosisReportsRequest(); request.withInstanceId("{instance_id}");
ListInstanceConsumerGroupsRequest request = new ListInstanceConsumerGroupsRequest(); request.withInstanceId("{instance_id}");
used_storage_space Integer 已使用的消息存储空间,单位:GB。 dns_enable Boolean 实例是否开启域名访问功能。 true:开启 false:未开启 connect_address String 实例连接IP地址。 port Integer
build() try: request = ShowMaintainWindowsRequest() response = client.show_maintain_windows(request) print(response)
DeleteSinkTaskRequest request = new DeleteSinkTaskRequest(); try { DeleteSinkTaskResponse response = client.deleteSinkTask(request);