更新时间:2024-10-25 GMT+08:00

变更分区数量

参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
// 目标分区数量
int targetPartitionCount = 2;
        
UpdatePartitionCountRequest update = new UpdatePartitionCountRequest();
update.setStreamName(streamName);
update.setTargetPartitionCount(targetPartitionCount);
try
{
     UpdatePartitionCountResult updatePartitionCountResult = dic.updatePartitionCount(update);
     LOGGER.info("Success to update partition count, {}", updatePartitionCountResult);
}
catch (Exception e)
{
     LOGGER.error("Failed to update partition count", e);
}

变更分区数量成功的返回信息如下。

1
Success to update partition count, UpdatePartitionCountResult [currentPartitionCount=2, streamName=mystream, targetPartitionCount=2]