Skip to content

Commit 6a05d70

Browse files
Qingtang-SDKQingtang-SDK
committed
ALIKAFKA SDK Auto Released By zyh.zyh,Version：1.0.5
发布日志： 1, update the core version
1 parent 342666d commit 6a05d70

18 files changed

+438
-16
lines changed

‎aliyun-java-sdk-alikafka/ChangeLog.txt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
2019-03-14 Version: 1.0.5
2+
1, update the core version
3+
14
2018-10-25 Version: 1.0.1
25
1, GetConsumerProgressResponse.OffsetListItem add partition property
36

‎aliyun-java-sdk-alikafka/pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<groupId>com.aliyun</groupId>
44
<artifactId>aliyun-java-sdk-alikafka</artifactId>
55
<packaging>jar</packaging>
6-
<version>1.0.1</version>
6+
<version>1.0.5</version>
77
<name>aliyun-java-sdk-alikafka</name>
88
<url>http://www.aliyun.com</url>
99
<description>Aliyun Open API SDK for Java
@@ -31,7 +31,7 @@ http://www.aliyun.com</description>
3131
<groupId>com.aliyun</groupId>
3232
<artifactId>aliyun-java-sdk-core</artifactId>
3333
<optional>true</optional>
34-
<version>4.1.1</version>
34+
<version>[4.3.2,5.0.0)</version>
3535
</dependency>
3636
</dependencies>
3737
<licenses>

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/CreateConsumerGroupRequest.java

Lines changed: 62 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
/*
2+
* Licensed under the Apache License, Version 2.0 (the "License");
3+
* you may not use this file except in compliance with the License.
4+
* You may obtain a copy of the License at
5+
*
6+
* http://www.apache.org/licenses/LICENSE-2.0
7+
*
8+
* Unless required by applicable law or agreed to in writing, software
9+
* distributed under the License is distributed on an "AS IS" BASIS,
10+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11+
* See the License for the specific language governing permissions and
12+
* limitations under the License.
13+
*/
14+
15+
package com.aliyuncs.alikafka.model.v20181015;
16+
17+
import com.aliyuncs.RpcAcsRequest;
18+
import com.aliyuncs.http.MethodType;
19+
20+
/**
21+
* @author auto create
22+
* @version
23+
*/
24+
public class CreateConsumerGroupRequest extends RpcAcsRequest<CreateConsumerGroupResponse> {
25+
26+
public CreateConsumerGroupRequest() {
27+
super("alikafka", "2018-10-15", "CreateConsumerGroup", "alikafka");
28+
setMethod(MethodType.POST);
29+
}
30+
31+
private String instanceId;
32+
33+
private String consumerId;
34+
35+
public String getInstanceId() {
36+
return this.instanceId;
37+
}
38+
39+
public void setInstanceId(String instanceId) {
40+
this.instanceId = instanceId;
41+
if(instanceId != null){
42+
putQueryParameter("InstanceId", instanceId);
43+
}
44+
}
45+
46+
public String getConsumerId() {
47+
return this.consumerId;
48+
}
49+
50+
public void setConsumerId(String consumerId) {
51+
this.consumerId = consumerId;
52+
if(consumerId != null){
53+
putQueryParameter("ConsumerId", consumerId);
54+
}
55+
}
56+
57+
@Override
58+
public Class<CreateConsumerGroupResponse> getResponseClass() {
59+
return CreateConsumerGroupResponse.class;
60+
}
61+
62+
}

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/CreateConsumerGroupResponse.java

Lines changed: 71 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,71 @@
1+
/*
2+
* Licensed under the Apache License, Version 2.0 (the "License");
3+
* you may not use this file except in compliance with the License.
4+
* You may obtain a copy of the License at
5+
*
6+
* http://www.apache.org/licenses/LICENSE-2.0
7+
*
8+
* Unless required by applicable law or agreed to in writing, software
9+
* distributed under the License is distributed on an "AS IS" BASIS,
10+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11+
* See the License for the specific language governing permissions and
12+
* limitations under the License.
13+
*/
14+
15+
package com.aliyuncs.alikafka.model.v20181015;
16+
17+
import com.aliyuncs.AcsResponse;
18+
import com.aliyuncs.alikafka.transform.v20181015.CreateConsumerGroupResponseUnmarshaller;
19+
import com.aliyuncs.transform.UnmarshallerContext;
20+
21+
/**
22+
* @author auto create
23+
* @version
24+
*/
25+
public class CreateConsumerGroupResponse extends AcsResponse {
26+
27+
private Boolean success;
28+
29+
private String requestId;
30+
31+
private Integer code;
32+
33+
private String message;
34+
35+
public Boolean getSuccess() {
36+
return this.success;
37+
}
38+
39+
public void setSuccess(Boolean success) {
40+
this.success = success;
41+
}
42+
43+
public String getRequestId() {
44+
return this.requestId;
45+
}
46+
47+
public void setRequestId(String requestId) {
48+
this.requestId = requestId;
49+
}
50+
51+
public Integer getCode() {
52+
return this.code;
53+
}
54+
55+
public void setCode(Integer code) {
56+
this.code = code;
57+
}
58+
59+
public String getMessage() {
60+
return this.message;
61+
}
62+
63+
public void setMessage(String message) {
64+
this.message = message;
65+
}
66+
67+
@Override
68+
public CreateConsumerGroupResponse getInstance(UnmarshallerContext context) {
69+
return CreateConsumerGroupResponseUnmarshaller.unmarshall(this, context);
70+
}
71+
}

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/CreateTopicRequest.java

Lines changed: 88 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,88 @@
1+
/*
2+
* Licensed under the Apache License, Version 2.0 (the "License");
3+
* you may not use this file except in compliance with the License.
4+
* You may obtain a copy of the License at
5+
*
6+
* http://www.apache.org/licenses/LICENSE-2.0
7+
*
8+
* Unless required by applicable law or agreed to in writing, software
9+
* distributed under the License is distributed on an "AS IS" BASIS,
10+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11+
* See the License for the specific language governing permissions and
12+
* limitations under the License.
13+
*/
14+
15+
package com.aliyuncs.alikafka.model.v20181015;
16+
17+
import com.aliyuncs.RpcAcsRequest;
18+
import com.aliyuncs.http.MethodType;
19+
20+
/**
21+
* @author auto create
22+
* @version
23+
*/
24+
public class CreateTopicRequest extends RpcAcsRequest<CreateTopicResponse> {
25+
26+
public CreateTopicRequest() {
27+
super("alikafka", "2018-10-15", "CreateTopic", "alikafka");
28+
setMethod(MethodType.POST);
29+
}
30+
31+
private String instanceId;
32+
33+
private String topic;
34+
35+
private String remark;
36+
37+
private Integer orderType;
38+
39+
public String getInstanceId() {
40+
return this.instanceId;
41+
}
42+
43+
public void setInstanceId(String instanceId) {
44+
this.instanceId = instanceId;
45+
if(instanceId != null){
46+
putQueryParameter("InstanceId", instanceId);
47+
}
48+
}
49+
50+
public String getTopic() {
51+
return this.topic;
52+
}
53+
54+
public void setTopic(String topic) {
55+
this.topic = topic;
56+
if(topic != null){
57+
putQueryParameter("Topic", topic);
58+
}
59+
}
60+
61+
public String getRemark() {
62+
return this.remark;
63+
}
64+
65+
public void setRemark(String remark) {
66+
this.remark = remark;
67+
if(remark != null){
68+
putQueryParameter("Remark", remark);
69+
}
70+
}
71+
72+
public Integer getOrderType() {
73+
return this.orderType;
74+
}
75+
76+
public void setOrderType(Integer orderType) {
77+
this.orderType = orderType;
78+
if(orderType != null){
79+
putQueryParameter("OrderType", orderType.toString());
80+
}
81+
}
82+
83+
@Override
84+
public Class<CreateTopicResponse> getResponseClass() {
85+
return CreateTopicResponse.class;
86+
}
87+
88+
}

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/CreateTopicResponse.java

Lines changed: 71 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,71 @@
1+
/*
2+
* Licensed under the Apache License, Version 2.0 (the "License");
3+
* you may not use this file except in compliance with the License.
4+
* You may obtain a copy of the License at
5+
*
6+
* http://www.apache.org/licenses/LICENSE-2.0
7+
*
8+
* Unless required by applicable law or agreed to in writing, software
9+
* distributed under the License is distributed on an "AS IS" BASIS,
10+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11+
* See the License for the specific language governing permissions and
12+
* limitations under the License.
13+
*/
14+
15+
package com.aliyuncs.alikafka.model.v20181015;
16+
17+
import com.aliyuncs.AcsResponse;
18+
import com.aliyuncs.alikafka.transform.v20181015.CreateTopicResponseUnmarshaller;
19+
import com.aliyuncs.transform.UnmarshallerContext;
20+
21+
/**
22+
* @author auto create
23+
* @version
24+
*/
25+
public class CreateTopicResponse extends AcsResponse {
26+
27+
private Boolean success;
28+
29+
private String requestId;
30+
31+
private Integer code;
32+
33+
private String message;
34+
35+
public Boolean getSuccess() {
36+
return this.success;
37+
}
38+
39+
public void setSuccess(Boolean success) {
40+
this.success = success;
41+
}
42+
43+
public String getRequestId() {
44+
return this.requestId;
45+
}
46+
47+
public void setRequestId(String requestId) {
48+
this.requestId = requestId;
49+
}
50+
51+
public Integer getCode() {
52+
return this.code;
53+
}
54+
55+
public void setCode(Integer code) {
56+
this.code = code;
57+
}
58+
59+
public String getMessage() {
60+
return this.message;
61+
}
62+
63+
public void setMessage(String message) {
64+
this.message = message;
65+
}
66+
67+
@Override
68+
public CreateTopicResponse getInstance(UnmarshallerContext context) {
69+
return CreateTopicResponseUnmarshaller.unmarshall(this, context);
70+
}
71+
}

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/GetConsumerListResponse.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,26 @@ public static class ConsumerListItem {
8383

8484
private String consumerId;
8585

86+
public String getBizRegionId() {
87+
return this.regionId;
88+
}
89+
90+
public void setBizRegionId(String regionId) {
91+
this.regionId = regionId;
92+
}
93+
94+
/**
95+
* @deprecated use getBizRegionId instead of this.
96+
*/
97+
@Deprecated
8698
public String getRegionId() {
8799
return this.regionId;
88100
}
89101

102+
/**
103+
* @deprecated use setBizRegionId instead of this.
104+
*/
105+
@Deprecated
90106
public void setRegionId(String regionId) {
91107
this.regionId = regionId;
92108
}

‎aliyun-java-sdk-alikafka/src/main/java/com/aliyuncs/alikafka/model/v20181015/GetConsumerProgressResponse.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,7 @@
1414

1515
package com.aliyuncs.alikafka.model.v20181015;
1616

17-
import java.util.List;
18-
import java.util.Map;
17+
import java.util.List;
1918
import com.aliyuncs.AcsResponse;
2019
import com.aliyuncs.alikafka.transform.v20181015.GetConsumerProgressResponseUnmarshaller;
2120
import com.aliyuncs.transform.UnmarshallerContext;

0 commit comments

Comments
 (0)