检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息超过老化时间，消息仍存在的原因 问题现象：消息超过设置的老化时间（如果Topic已经设置了老化时间，此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时，“配置参数”中的log.retention.hours值才会对此Topic生效。），消息仍存在。
DeleteSinkTaskRequest request = new DeleteSinkTaskRequest(); try { DeleteSinkTaskResponse response = client.deleteSinkTask(request);
build() try: request = ShowMaintainWindowsRequest() response = client.show_maintain_windows(request) print(response)
ListSinkTasksRequest request = new ListSinkTasksRequest(); try { ListSinkTasksResponse response = client.listSinkTasks(request);
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}");
request = ShowCesHierarchyRequest() request.instance_id = "{instance_id}" response = client.show_ces_hierarchy(request)
build() try: request = ListAvailableZonesRequest() response = client.list_available_zones(request) print(response)
try: request = ShowEngineInstanceExtendProductInfoRequest() request.engine = "{engine}" request.instance_id = "{instance_id}"
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和分区问题
endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 在Kafka客户端的“/bin”目录下，通过以下命令查询消费组列表。
password=dms@kafka #ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭，这里需要保持关闭状态，必须设置为空。 ssl.endpoint.identification.algorithm= #添加ssl.truststore
endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 在Kafka客户端的“/bin”目录下，通过以下命令删除Topic。
endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 在Kafka客户端的“/bin”目录下，通过以下命令修改Topic分区数。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
