Skip to content

Commit 7d247b1

Browse files
sdk-teamsdk-team
committed
Generated Darabonba for alikafka-2019-09-16.
1 parent 516666e commit 7d247b1

File tree

7 files changed

+303
-104
lines changed

7 files changed

+303
-104
lines changed

‎alikafka-20190916/Teafile

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@
2323
}
2424
},
2525
"releases": {
26-
"java": "com.aliyun:alikafka20190916:1.10.2",
27-
"go": "github.com/alibabacloud-go/alikafka-20190916/v3/client:v3.11.2",
28-
"csharp": "AlibabaCloud.SDK.Alikafka20190916:2.10.2",
29-
"ts": "@alicloud/alikafka20190916:2.8.2",
30-
"php": "alibabacloud/alikafka-20190916:2.9.2",
31-
"python": "alibabacloud_alikafka20190916:2.10.2",
26+
"java": "com.aliyun:alikafka20190916:1.11.0",
27+
"go": "github.com/alibabacloud-go/alikafka-20190916/v3/client:v3.12.0",
28+
"csharp": "AlibabaCloud.SDK.Alikafka20190916:2.11.0",
29+
"ts": "@alicloud/alikafka20190916:2.9.0",
30+
"php": "alibabacloud/alikafka-20190916:2.10.0",
31+
"python": "alibabacloud_alikafka20190916:2.11.0",
3232
"python2": "alibabacloud_alikafka20190916_py2:2.6.6",
33-
"cpp": "alibabacloud-sdk-cpp/alikafka-20190916:1.10.2",
34-
"swift": "alibabacloud-sdk-swift/alikafka-20190916:1.7.4"
33+
"cpp": "alibabacloud-sdk-cpp/alikafka-20190916:1.11.0",
34+
"swift": "alibabacloud-sdk-swift/alikafka-20190916:1.8.0"
3535
},
3636
"libraries": {
3737
"OpenApi": "alibabacloud:OpenApi:*",

‎alikafka-20190916/api-info.json

Lines changed: 33 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -3,58 +3,59 @@
33
"version": "2019-09-16",
44
"apiDoc": {
55
"hasDoc": [
6-
"DeleteConsumerGroup",
76
"ReleaseInstance",
7+
"DeleteConsumerGroup",
88
"ChangeResourceGroup",
99
"ConvertPostPayOrder",
1010
"CreateAcl",
1111
"CreateConsumerGroup",
12-
"CreatePostPayInstance",
12+
"CreatePostPayOrder",
1313
"CreatePrePayOrder",
14+
"CreateTopic",
1415
"DeleteTopic",
16+
"CreatePostPayInstance",
1517
"DeleteScheduledScalingRule",
16-
"DeleteInstance",
17-
"GetTopicList",
18-
"CreatePrePayInstance",
19-
"CreateSaslUser",
18+
"GetTopicSubscribeStatus",
2019
"CreateScheduledScalingRule",
20+
"GetTopicStatus",
2121
"DeleteSaslUser",
22-
"EnableAutoTopicCreation",
23-
"CreateTopic",
24-
"GetTopicSubscribeStatus",
22+
"ModifyPartitionNum",
23+
"GetAllowedIpList",
2524
"DescribeAclResourceName",
26-
"GetAutoScalingConfiguration",
27-
"GetConsumerList",
28-
"GetKafkaClientIp",
29-
"DeleteAcl",
25+
"ReopenInstance",
3026
"GetQuotaTip",
31-
"GetTopicStatus",
32-
"GetAllowedIpList",
27+
"TagResources",
28+
"DescribeSaslUsers",
29+
"UpdateInstanceConfig",
30+
"UpgradePostPayOrder",
31+
"CreatePrePayInstance",
32+
"DeleteInstance",
33+
"CreateSaslUser",
3334
"EnableAutoGroupCreation",
35+
"GetConsumerList",
36+
"GetAutoScalingConfiguration",
37+
"GetConsumerProgress",
3438
"DescribeAcls",
35-
"DescribeSaslUsers",
36-
"GetInstanceList",
39+
"DeleteAcl",
40+
"GetTopicList",
3741
"GetAllInstanceIdList",
38-
"GetConsumerProgress",
39-
"ListTagResources",
40-
"ModifyInstanceName",
41-
"ModifyPartitionNum",
42-
"ModifyScheduledScalingRule",
43-
"ModifyTopicRemark",
4442
"QueryMessage",
45-
"ReopenInstance",
46-
"StartInstance",
43+
"EnableAutoTopicCreation",
4744
"StopInstance",
48-
"UpgradePrePayOrder",
49-
"CreatePostPayOrder",
45+
"ListRebalanceInfo",
5046
"UpdateAllowedIp",
51-
"UpgradePostPayOrder",
47+
"UntagResources",
48+
"ModifyTopicRemark",
49+
"ModifyScheduledScalingRule",
5250
"UpdateConsumerOffset",
51+
"StartInstance",
52+
"UpgradePrePayOrder",
53+
"GetInstanceList",
54+
"ModifyInstanceName",
55+
"ListTagResources",
56+
"GetKafkaClientIp",
5357
"UpdateTopicConfig",
54-
"UpdateInstanceConfig",
55-
"UpgradeInstanceVersion",
56-
"TagResources",
57-
"UntagResources"
58+
"UpgradeInstanceVersion"
5859
],
5960
"noDoc": []
6061
},

‎alikafka-20190916/async/api-info.json

Lines changed: 40 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -3,58 +3,59 @@
33
"version": "2019-09-16",
44
"apiDoc": {
55
"hasDoc": [
6-
"DeleteConsumerGroup",
6+
"ChangeResourceGroup",
77
"UpgradePrePayOrder",
8-
"ReleaseInstance",
9-
"CreateSaslUser",
10-
"CreateTopic",
11-
"DeleteScheduledScalingRule",
12-
"DeleteTopic",
13-
"DeleteAcl",
14-
"CreatePrePayOrder",
15-
"GetTopicList",
16-
"CreateScheduledScalingRule",
8+
"DeleteConsumerGroup",
9+
"GetConsumerList",
10+
"GetAllInstanceIdList",
1711
"DeleteSaslUser",
18-
"DescribeSaslUsers",
19-
"CreatePrePayInstance",
20-
"EnableAutoGroupCreation",
12+
"GetTopicList",
13+
"GetQuotaTip",
14+
"CreateAcl",
15+
"GetKafkaClientIp",
16+
"DeleteInstance",
17+
"DeleteTopic",
2118
"GetTopicSubscribeStatus",
22-
"GetAllInstanceIdList",
2319
"EnableAutoTopicCreation",
24-
"ModifyPartitionNum",
25-
"GetConsumerList",
20+
"GetTopicStatus",
2621
"ModifyInstanceName",
27-
"GetKafkaClientIp",
28-
"GetAllowedIpList",
29-
"GetConsumerProgress",
30-
"StartInstance",
3122
"DescribeAcls",
32-
"GetAutoScalingConfiguration",
33-
"ModifyTopicRemark",
3423
"ListTagResources",
35-
"GetQuotaTip",
36-
"UntagResources",
37-
"GetTopicStatus",
38-
"TagResources",
24+
"ModifyPartitionNum",
25+
"GetAutoScalingConfiguration",
3926
"GetInstanceList",
40-
"UpdateAllowedIp",
41-
"UpdateInstanceConfig",
42-
"ModifyScheduledScalingRule",
27+
"TagResources",
28+
"DescribeAclResourceName",
29+
"EnableAutoGroupCreation",
30+
"CreateScheduledScalingRule",
31+
"UntagResources",
32+
"UpdateTopicConfig",
4333
"UpgradePostPayOrder",
44-
"ChangeResourceGroup",
45-
"ConvertPostPayOrder",
4634
"CreatePostPayInstance",
47-
"DescribeAclResourceName",
48-
"CreatePostPayOrder",
35+
"CreatePrePayOrder",
4936
"CreateConsumerGroup",
50-
"QueryMessage",
37+
"CreateTopic",
38+
"DeleteAcl",
39+
"CreateSaslUser",
40+
"DeleteScheduledScalingRule",
41+
"CreatePrePayInstance",
42+
"CreatePostPayOrder",
43+
"ReleaseInstance",
44+
"GetConsumerProgress",
45+
"ListRebalanceInfo",
46+
"GetAllowedIpList",
47+
"UpdateInstanceConfig",
48+
"ModifyScheduledScalingRule",
5149
"UpdateConsumerOffset",
52-
"UpdateTopicConfig",
53-
"ReopenInstance",
50+
"QueryMessage",
51+
"ModifyTopicRemark",
52+
"UpdateAllowedIp",
53+
"UpgradeInstanceVersion",
54+
"StartInstance",
5455
"StopInstance",
55-
"CreateAcl",
56-
"DeleteInstance",
57-
"UpgradeInstanceVersion"
56+
"ReopenInstance",
57+
"DescribeSaslUsers",
58+
"ConvertPostPayOrder"
5859
],
5960
"noDoc": []
6061
},

‎alikafka-20190916/async/main.dara

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2209,6 +2209,46 @@ async function getTopicSubscribeStatus(request: GetTopicSubscribeStatusRequest):
22092209
return @handler.do('RPC', 'GetTopicSubscribeStatus', 'POST', '/', 'json', false, 'json', request);
22102210
}
22112211

2212+
model ListRebalanceInfoRequest {
2213+
consumerId: string(name='ConsumerId', description='This parameter is required.', example='kafka-test', position='Query'),
2214+
instanceId: string(name='InstanceId', description='This parameter is required.', example='alikafka_pre-cn-v0h1cng0****', position='Query'),
2215+
regionId: string(name='RegionId', description='This parameter is required.', example='cn-hangzhou', position='Query'),
2216+
}
2217+
2218+
model ListRebalanceInfoResponseBody = {
2219+
code?: int32(name='Code', example='200'),
2220+
data?: {
2221+
rebalanceInfoList?: [
2222+
{
2223+
generation?: long(name='Generation', example='100'),
2224+
groupId?: string(name='GroupId', example='kafka-test'),
2225+
lastRebalanceTimestamp?: long(name='LastRebalanceTimestamp', example='1709199270'),
2226+
reason?: string(name='Reason', example='removing member consumer-1-cd14eb9c-379b-4b8e-9bbd-76f147f8536f on LeaveGroup'),
2227+
rebalanceSuccess?: boolean(name='RebalanceSuccess', example='true'),
2228+
rebalanceTimeConsuming?: long(name='RebalanceTimeConsuming', example='12'),
2229+
}
2230+
](name='RebalanceInfoList')
2231+
}(name='Data'),
2232+
message?: string(name='Message', example='operation success.'),
2233+
requestId?: string(name='RequestId', example='06084011-E093-46F3-A51F-4B19A8AD****'),
2234+
success?: boolean(name='Success', example='true'),
2235+
}
2236+
2237+
model ListRebalanceInfoResponse = {
2238+
headers?: map[string]string(name='headers'),
2239+
statusCode?: int32(name='statusCode'),
2240+
body?: ListRebalanceInfoResponseBody(name='body'),
2241+
}
2242+
2243+
/**
2244+
* @param request the request parameters of ListRebalanceInfo ListRebalanceInfoRequest
2245+
* @return ListRebalanceInfoResponse
2246+
*/
2247+
async function listRebalanceInfo(request: ListRebalanceInfoRequest): ListRebalanceInfoResponse {
2248+
@handler.validateRequestModel(request);
2249+
return @handler.do('RPC', 'ListRebalanceInfo', 'POST', '/', 'json', false, 'json', request);
2250+
}
2251+
22122252
model ListTagResourcesRequest {
22132253
nextToken?: string(name='NextToken', description='The token that determines the start point of the next query.', example='caeba0bbb2be03f84eb48b699f0a4883', position='Query'),
22142254
regionId: string(name='RegionId', description='The ID of the region in which the resource is deployed.

‎alikafka-20190916/main.tea

Lines changed: 78 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4079,6 +4079,84 @@ async function getTopicSubscribeStatus(request: GetTopicSubscribeStatusRequest):
40794079
return getTopicSubscribeStatusWithOptions(request, runtime);
40804080
}
40814081

4082+
model ListRebalanceInfoRequest {
4083+
consumerId?: string(name='ConsumerId', description='This parameter is required.', example='kafka-test'),
4084+
instanceId?: string(name='InstanceId', description='This parameter is required.', example='alikafka_pre-cn-v0h1cng0****'),
4085+
regionId?: string(name='RegionId', description='This parameter is required.', example='cn-hangzhou'),
4086+
}
4087+
4088+
model ListRebalanceInfoResponseBody = {
4089+
code?: int32(name='Code', example='200'),
4090+
data?: {
4091+
rebalanceInfoList?: [
4092+
{
4093+
generation?: long(name='Generation', example='100'),
4094+
groupId?: string(name='GroupId', example='kafka-test'),
4095+
lastRebalanceTimestamp?: long(name='LastRebalanceTimestamp', example='1709199270'),
4096+
reason?: string(name='Reason', example='removing member consumer-1-cd14eb9c-379b-4b8e-9bbd-76f147f8536f on LeaveGroup'),
4097+
rebalanceSuccess?: boolean(name='RebalanceSuccess', example='true'),
4098+
rebalanceTimeConsuming?: long(name='RebalanceTimeConsuming', example='12'),
4099+
}
4100+
](name='RebalanceInfoList')
4101+
}(name='Data'),
4102+
message?: string(name='Message', example='operation success.'),
4103+
requestId?: string(name='RequestId', example='06084011-E093-46F3-A51F-4B19A8AD****'),
4104+
success?: boolean(name='Success', example='true'),
4105+
}
4106+
4107+
model ListRebalanceInfoResponse = {
4108+
headers?: map[string]string(name='headers'),
4109+
statusCode?: int32(name='statusCode'),
4110+
body?: ListRebalanceInfoResponseBody(name='body'),
4111+
}
4112+
4113+
/**
4114+
* @summary 获取Rebalance详情
4115+
*
4116+
* @param request ListRebalanceInfoRequest
4117+
* @param runtime runtime options for this request RuntimeOptions
4118+
* @return ListRebalanceInfoResponse
4119+
*/
4120+
async function listRebalanceInfoWithOptions(request: ListRebalanceInfoRequest, runtime: Util.RuntimeOptions): ListRebalanceInfoResponse {
4121+
Util.validateModel(request);
4122+
var query = {};
4123+
if (!Util.isUnset(request.consumerId)) {
4124+
query['ConsumerId'] = request.consumerId;
4125+
}
4126+
if (!Util.isUnset(request.instanceId)) {
4127+
query['InstanceId'] = request.instanceId;
4128+
}
4129+
if (!Util.isUnset(request.regionId)) {
4130+
query['RegionId'] = request.regionId;
4131+
}
4132+
var req = new OpenApi.OpenApiRequest{
4133+
query = OpenApiUtil.query(query),
4134+
};
4135+
var params = new OpenApi.Params{
4136+
action = 'ListRebalanceInfo',
4137+
version = '2019-09-16',
4138+
protocol = 'HTTPS',
4139+
pathname = '/',
4140+
method = 'POST',
4141+
authType = 'AK',
4142+
style = 'RPC',
4143+
reqBodyType = 'formData',
4144+
bodyType = 'json',
4145+
};
4146+
return callApi(params, req, runtime);
4147+
}
4148+
4149+
/**
4150+
* @summary 获取Rebalance详情
4151+
*
4152+
* @param request ListRebalanceInfoRequest
4153+
* @return ListRebalanceInfoResponse
4154+
*/
4155+
async function listRebalanceInfo(request: ListRebalanceInfoRequest): ListRebalanceInfoResponse {
4156+
var runtime = new Util.RuntimeOptions{};
4157+
return listRebalanceInfoWithOptions(request, runtime);
4158+
}
4159+
40824160
model ListTagResourcesRequest {
40834161
nextToken?: string(name='NextToken', description='The token that determines the start point of the next query.', example='caeba0bbb2be03f84eb48b699f0a4883'),
40844162
regionId?: string(name='RegionId', description='The ID of the region in which the resource is deployed.

0 commit comments

Comments
 (0)