检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
build(); ShowInstanceConfigsRequest request = new ShowInstanceConfigsRequest(); request.withInstanceId("{instance_id}");
build(); ShowInstanceMessagesRequest request = new ShowInstanceMessagesRequest(); request.withInstanceId("{instance_id}");
3，重试间隔retry.backoff.ms=1000。 request.timeout.ms 30000 结合实际业务调整 设置一个请求最大等待时间（单位为ms），超过这个时间则会抛Timeout异常。 超时时间如果设置大一些，如127000（127秒），高并发的场景中，能减少发送失败的情况。
build() try: request = ShowKafkaProjectTagsRequest() response = client.show_kafka_project_tags(request) print(response)
request = ShowCesHierarchyRequest() request.instance_id = "{instance_id}" response = client.show_ces_hierarchy(request)
build(); ShowSinkTaskDetailRequest request = new ShowSinkTaskDetailRequest(); request.withTopicInfo(ShowSinkTaskDetailRequest.TopicInfoEnum
ShowConnectorTaskRequest request = new ShowConnectorTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
build(); UpdateInstanceTopicRequest request = new UpdateInstanceTopicRequest(); request.withInstanceId("{instance_id}");
ShowKafkaTopicPartitionDiskusageRequest request = new ShowKafkaTopicPartitionDiskusageRequest(); request.withInstanceId("{instance_id}");
build() try: request = ListAvailableZonesRequest() response = client.list_available_zones(request) print(response)
ListSinkTasksRequest request = new ListSinkTasksRequest(); try { ListSinkTasksResponse response = client.listSinkTasks(request);
消息超过老化时间，消息仍存在的原因 问题现象：消息超过设置的老化时间（如果Topic已经设置了老化时间，此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时，“配置参数”中的log.retention.hours值才会对此Topic生效。），消息仍存在。
try: request = ShowEngineInstanceExtendProductInfoRequest() request.engine = "{engine}" request.instance_id = "{instance_id}"
endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 在Kafka客户端的“/bin”目录下，通过以下命令删除Topic。
build(); CreateReassignmentTaskRequest request = new CreateReassignmentTaskRequest(); request.withInstanceId("{instance_id}");
request = ListEngineProductsRequest() request.engine = "{engine}" response = client.list_engine_products(request)
truststore.jks的密码。 ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 ssl.keystore.location配置为client.keystore.jks证书的存放路径。
build(); CreateInstanceByEngineRequest request = new CreateInstanceByEngineRequest(); request.withEngine(CreateInstanceByEngineRequest
build(); ListConnectorTasksRequest request = new ListConnectorTasksRequest(); request.withInstanceId("{instance_id}");
Kafka支持减少分区数吗？ Kafka不支持减少分区数，您可以通过删除原先的Topic，然后创建新Topic，重新设置分区数。 父主题： Topic和分区问题
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
