Skip to content

Commit e8122c8

Browse files
committed
Supported use group by freedom
1 parent 9a0c45b commit e8122c8

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

46 files changed

+500
-62
lines changed

aliyun-python-sdk-alikafka/ChangeLog.txt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
2024-04-03 Version: 1.0.6
2+
- Supported use group by freedom
3+
14
2023-04-25 Version: 1.0.5
25
- Add UpdateConsumerOffset api.
36

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '1.0.5'
1+
__version__ = '1.0.6'

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/ChangeResourceGroupRequest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class ChangeResourceGroupRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'ChangeResourceGroup')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'ChangeResourceGroup','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/ConvertPostPayOrderRequest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class ConvertPostPayOrderRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'ConvertPostPayOrder')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'ConvertPostPayOrder','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreateAclRequest.py

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class CreateAclRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateAcl')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateAcl','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):
@@ -41,6 +41,11 @@ def get_AclResourceType(self): # String
4141

4242
def set_AclResourceType(self, AclResourceType): # String
4343
self.add_query_param('AclResourceType', AclResourceType)
44+
def get_AclOperationTypes(self): # String
45+
return self.get_query_params().get('AclOperationTypes')
46+
47+
def set_AclOperationTypes(self, AclOperationTypes): # String
48+
self.add_query_param('AclOperationTypes', AclOperationTypes)
4449
def get_AclOperationType(self): # String
4550
return self.get_query_params().get('AclOperationType')
4651

@@ -56,6 +61,16 @@ def get_InstanceId(self): # String
5661

5762
def set_InstanceId(self, InstanceId): # String
5863
self.add_query_param('InstanceId', InstanceId)
64+
def get_Host(self): # String
65+
return self.get_query_params().get('Host')
66+
67+
def set_Host(self, Host): # String
68+
self.add_query_param('Host', Host)
69+
def get_AclPermissionType(self): # String
70+
return self.get_query_params().get('AclPermissionType')
71+
72+
def set_AclPermissionType(self, AclPermissionType): # String
73+
self.add_query_param('AclPermissionType', AclPermissionType)
5974
def get_Username(self): # String
6075
return self.get_query_params().get('Username')
6176

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreateConsumerGroupRequest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class CreateConsumerGroupRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateConsumerGroup')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateConsumerGroup','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreatePostPayOrderRequest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class CreatePostPayOrderRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreatePostPayOrder')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreatePostPayOrder','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreatePrePayOrderRequest.py

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,12 @@
1919

2020
from aliyunsdkcore.request import RpcRequest
2121
from aliyunsdkalikafka.endpoint import endpoint_data
22+
import json
2223

2324
class CreatePrePayOrderRequest(RpcRequest):
2425

2526
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreatePrePayOrder')
27+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreatePrePayOrder','alikafka')
2728
self.set_method('POST')
2829

2930
if hasattr(self, "endpoint_map"):
@@ -41,6 +42,11 @@ def get_EipMax(self): # Integer
4142

4243
def set_EipMax(self, EipMax): # Integer
4344
self.add_query_param('EipMax', EipMax)
45+
def get_Duration(self): # Integer
46+
return self.get_query_params().get('Duration')
47+
48+
def set_Duration(self, Duration): # Integer
49+
self.add_query_param('Duration', Duration)
4450
def get_SpecType(self): # String
4551
return self.get_query_params().get('SpecType')
4652

@@ -51,6 +57,11 @@ def get_ResourceGroupId(self): # String
5157

5258
def set_ResourceGroupId(self, ResourceGroupId): # String
5359
self.add_query_param('ResourceGroupId', ResourceGroupId)
60+
def get_ConfluentConfig(self): # Struct
61+
return self.get_query_params().get('ConfluentConfig')
62+
63+
def set_ConfluentConfig(self, ConfluentConfig): # Struct
64+
self.add_query_param("ConfluentConfig", json.dumps(ConfluentConfig))
5465
def get_Tags(self): # RepeatList
5566
return self.get_query_params().get('Tag')
5667

@@ -65,6 +76,11 @@ def get_PartitionNum(self): # Integer
6576

6677
def set_PartitionNum(self, PartitionNum): # Integer
6778
self.add_query_param('PartitionNum', PartitionNum)
79+
def get_PaidType(self): # Integer
80+
return self.get_query_params().get('PaidType')
81+
82+
def set_PaidType(self, PaidType): # Integer
83+
self.add_query_param('PaidType', PaidType)
6884
def get_DiskSize(self): # Integer
6985
return self.get_query_params().get('DiskSize')
7086

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreateSaslUserRequest.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class CreateSaslUserRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateSaslUser')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateSaslUser','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):
@@ -46,6 +46,11 @@ def get_InstanceId(self): # String
4646

4747
def set_InstanceId(self, InstanceId): # String
4848
self.add_query_param('InstanceId', InstanceId)
49+
def get_Mechanism(self): # String
50+
return self.get_query_params().get('Mechanism')
51+
52+
def set_Mechanism(self, Mechanism): # String
53+
self.add_query_param('Mechanism', Mechanism)
4954
def get_Username(self): # String
5055
return self.get_query_params().get('Username')
5156

aliyun-python-sdk-alikafka/aliyunsdkalikafka/request/v20190916/CreateTopicRequest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
class CreateTopicRequest(RpcRequest):
2424

2525
def __init__(self):
26-
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateTopic')
26+
RpcRequest.__init__(self, 'alikafka', '2019-09-16', 'CreateTopic','alikafka')
2727
self.set_method('POST')
2828

2929
if hasattr(self, "endpoint_map"):

0 commit comments

Comments
 (0)