更新时间: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] |
父主题: 使用SDK(Java)