Skip to content

Conversation

tongyiming
Copy link
Collaborator

No description provided.

ValidateFunc: validateAllowedIntValue([]int{1, 2, 3, 4, 5, 6, 7, 8, 9}),
Description: "Description of instance type. `profession`: 1, `standard`: 1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).",
},
"upgrade_strategy": {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

这个参数应该不需要用户输入吧

request.Partition = helper.Int64(int64(v.(int)))
}

_, err := service.client.UseCkafkaClient().ModifyInstancePre(request)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

这里判断是否调用 ModifyInstancePre 还是 InstanceScalingDown 的依据是什么呢

Copy link
Collaborator

@andrew-tx andrew-tx left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@andrew-tx andrew-tx merged commit 1937ba6 into master Oct 13, 2023
@andrew-tx andrew-tx deleted the fix/ckafka-scaling-down branch October 13, 2023 11:06
andrew-tx added a commit that referenced this pull request Oct 13, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants