Supported use group by freedom

VERSION

@@ -1 +1 @@
-1.36.1887
+1.36.1888

alikafka/CMakeLists.txt

@@ -51,6 +51,10 @@ set(alikafka_public_header_model
 	include/alibabacloud/alikafka/model/DescribeAclsResult.h
 	include/alibabacloud/alikafka/model/DescribeSaslUsersRequest.h
 	include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h
+	include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h
+	include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h
+	include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h
+	include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h
 	include/alibabacloud/alikafka/model/GetAllInstanceIdListRequest.h
 	include/alibabacloud/alikafka/model/GetAllInstanceIdListResult.h
 	include/alibabacloud/alikafka/model/GetAllowedIpListRequest.h
@@ -67,6 +71,8 @@ set(alikafka_public_header_model
 	include/alibabacloud/alikafka/model/GetTopicListResult.h
 	include/alibabacloud/alikafka/model/GetTopicStatusRequest.h
 	include/alibabacloud/alikafka/model/GetTopicStatusResult.h
+	include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h
+	include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h
 	include/alibabacloud/alikafka/model/ListTagResourcesRequest.h
 	include/alibabacloud/alikafka/model/ListTagResourcesResult.h
 	include/alibabacloud/alikafka/model/ModifyInstanceNameRequest.h
@@ -75,10 +81,16 @@ set(alikafka_public_header_model
 	include/alibabacloud/alikafka/model/ModifyPartitionNumResult.h
 	include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h
 	include/alibabacloud/alikafka/model/ModifyTopicRemarkResult.h
+	include/alibabacloud/alikafka/model/QueryMessageRequest.h
+	include/alibabacloud/alikafka/model/QueryMessageResult.h
 	include/alibabacloud/alikafka/model/ReleaseInstanceRequest.h
 	include/alibabacloud/alikafka/model/ReleaseInstanceResult.h
+	include/alibabacloud/alikafka/model/ReopenInstanceRequest.h
+	include/alibabacloud/alikafka/model/ReopenInstanceResult.h
 	include/alibabacloud/alikafka/model/StartInstanceRequest.h
 	include/alibabacloud/alikafka/model/StartInstanceResult.h
+	include/alibabacloud/alikafka/model/StopInstanceRequest.h
+	include/alibabacloud/alikafka/model/StopInstanceResult.h
 	include/alibabacloud/alikafka/model/TagResourcesRequest.h
 	include/alibabacloud/alikafka/model/TagResourcesResult.h
 	include/alibabacloud/alikafka/model/UntagResourcesRequest.h
@@ -89,6 +101,8 @@ set(alikafka_public_header_model
 	include/alibabacloud/alikafka/model/UpdateConsumerOffsetResult.h
 	include/alibabacloud/alikafka/model/UpdateInstanceConfigRequest.h
 	include/alibabacloud/alikafka/model/UpdateInstanceConfigResult.h
+	include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h
+	include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h
 	include/alibabacloud/alikafka/model/UpgradeInstanceVersionRequest.h
 	include/alibabacloud/alikafka/model/UpgradeInstanceVersionResult.h
 	include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h
@@ -128,6 +142,10 @@ set(alikafka_src
 	src/model/DescribeAclsResult.cc
 	src/model/DescribeSaslUsersRequest.cc
 	src/model/DescribeSaslUsersResult.cc
+	src/model/EnableAutoGroupCreationRequest.cc
+	src/model/EnableAutoGroupCreationResult.cc
+	src/model/EnableAutoTopicCreationRequest.cc
+	src/model/EnableAutoTopicCreationResult.cc
 	src/model/GetAllInstanceIdListRequest.cc
 	src/model/GetAllInstanceIdListResult.cc
 	src/model/GetAllowedIpListRequest.cc
@@ -144,6 +162,8 @@ set(alikafka_src
 	src/model/GetTopicListResult.cc
 	src/model/GetTopicStatusRequest.cc
 	src/model/GetTopicStatusResult.cc
+	src/model/GetTopicSubscribeStatusRequest.cc
+	src/model/GetTopicSubscribeStatusResult.cc
 	src/model/ListTagResourcesRequest.cc
 	src/model/ListTagResourcesResult.cc
 	src/model/ModifyInstanceNameRequest.cc
@@ -152,10 +172,16 @@ set(alikafka_src
 	src/model/ModifyPartitionNumResult.cc
 	src/model/ModifyTopicRemarkRequest.cc
 	src/model/ModifyTopicRemarkResult.cc
+	src/model/QueryMessageRequest.cc
+	src/model/QueryMessageResult.cc
 	src/model/ReleaseInstanceRequest.cc
 	src/model/ReleaseInstanceResult.cc
+	src/model/ReopenInstanceRequest.cc
+	src/model/ReopenInstanceResult.cc
 	src/model/StartInstanceRequest.cc
 	src/model/StartInstanceResult.cc
+	src/model/StopInstanceRequest.cc
+	src/model/StopInstanceResult.cc
 	src/model/TagResourcesRequest.cc
 	src/model/TagResourcesResult.cc
 	src/model/UntagResourcesRequest.cc
@@ -166,6 +192,8 @@ set(alikafka_src
 	src/model/UpdateConsumerOffsetResult.cc
 	src/model/UpdateInstanceConfigRequest.cc
 	src/model/UpdateInstanceConfigResult.cc
+	src/model/UpdateTopicConfigRequest.cc
+	src/model/UpdateTopicConfigResult.cc
 	src/model/UpgradeInstanceVersionRequest.cc
 	src/model/UpgradeInstanceVersionResult.cc
 	src/model/UpgradePostPayOrderRequest.cc

alikafka/include/alibabacloud/alikafka/AlikafkaClient.h

@@ -52,6 +52,10 @@
 #include "model/DescribeAclsResult.h"
 #include "model/DescribeSaslUsersRequest.h"
 #include "model/DescribeSaslUsersResult.h"
+#include "model/EnableAutoGroupCreationRequest.h"
+#include "model/EnableAutoGroupCreationResult.h"
+#include "model/EnableAutoTopicCreationRequest.h"
+#include "model/EnableAutoTopicCreationResult.h"
 #include "model/GetAllInstanceIdListRequest.h"
 #include "model/GetAllInstanceIdListResult.h"
 #include "model/GetAllowedIpListRequest.h"
@@ -68,6 +72,8 @@
 #include "model/GetTopicListResult.h"
 #include "model/GetTopicStatusRequest.h"
 #include "model/GetTopicStatusResult.h"
+#include "model/GetTopicSubscribeStatusRequest.h"
+#include "model/GetTopicSubscribeStatusResult.h"
 #include "model/ListTagResourcesRequest.h"
 #include "model/ListTagResourcesResult.h"
 #include "model/ModifyInstanceNameRequest.h"
@@ -76,10 +82,16 @@
 #include "model/ModifyPartitionNumResult.h"
 #include "model/ModifyTopicRemarkRequest.h"
 #include "model/ModifyTopicRemarkResult.h"
+#include "model/QueryMessageRequest.h"
+#include "model/QueryMessageResult.h"
 #include "model/ReleaseInstanceRequest.h"
 #include "model/ReleaseInstanceResult.h"
+#include "model/ReopenInstanceRequest.h"
+#include "model/ReopenInstanceResult.h"
 #include "model/StartInstanceRequest.h"
 #include "model/StartInstanceResult.h"
+#include "model/StopInstanceRequest.h"
+#include "model/StopInstanceResult.h"
 #include "model/TagResourcesRequest.h"
 #include "model/TagResourcesResult.h"
 #include "model/UntagResourcesRequest.h"
@@ -90,6 +102,8 @@
 #include "model/UpdateConsumerOffsetResult.h"
 #include "model/UpdateInstanceConfigRequest.h"
 #include "model/UpdateInstanceConfigResult.h"
+#include "model/UpdateTopicConfigRequest.h"
+#include "model/UpdateTopicConfigResult.h"
 #include "model/UpgradeInstanceVersionRequest.h"
 #include "model/UpgradeInstanceVersionResult.h"
 #include "model/UpgradePostPayOrderRequest.h"
@@ -150,6 +164,12 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::DescribeSaslUsersResult> DescribeSaslUsersOutcome;
 			typedef std::future<DescribeSaslUsersOutcome> DescribeSaslUsersOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::DescribeSaslUsersRequest&, const DescribeSaslUsersOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DescribeSaslUsersAsyncHandler;
+			typedef Outcome<Error, Model::EnableAutoGroupCreationResult> EnableAutoGroupCreationOutcome;
+			typedef std::future<EnableAutoGroupCreationOutcome> EnableAutoGroupCreationOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::EnableAutoGroupCreationRequest&, const EnableAutoGroupCreationOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> EnableAutoGroupCreationAsyncHandler;
+			typedef Outcome<Error, Model::EnableAutoTopicCreationResult> EnableAutoTopicCreationOutcome;
+			typedef std::future<EnableAutoTopicCreationOutcome> EnableAutoTopicCreationOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::EnableAutoTopicCreationRequest&, const EnableAutoTopicCreationOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> EnableAutoTopicCreationAsyncHandler;
 			typedef Outcome<Error, Model::GetAllInstanceIdListResult> GetAllInstanceIdListOutcome;
 			typedef std::future<GetAllInstanceIdListOutcome> GetAllInstanceIdListOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::GetAllInstanceIdListRequest&, const GetAllInstanceIdListOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetAllInstanceIdListAsyncHandler;
@@ -174,6 +194,9 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::GetTopicStatusResult> GetTopicStatusOutcome;
 			typedef std::future<GetTopicStatusOutcome> GetTopicStatusOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::GetTopicStatusRequest&, const GetTopicStatusOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetTopicStatusAsyncHandler;
+			typedef Outcome<Error, Model::GetTopicSubscribeStatusResult> GetTopicSubscribeStatusOutcome;
+			typedef std::future<GetTopicSubscribeStatusOutcome> GetTopicSubscribeStatusOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::GetTopicSubscribeStatusRequest&, const GetTopicSubscribeStatusOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetTopicSubscribeStatusAsyncHandler;
 			typedef Outcome<Error, Model::ListTagResourcesResult> ListTagResourcesOutcome;
 			typedef std::future<ListTagResourcesOutcome> ListTagResourcesOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::ListTagResourcesRequest&, const ListTagResourcesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTagResourcesAsyncHandler;
@@ -186,12 +209,21 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::ModifyTopicRemarkResult> ModifyTopicRemarkOutcome;
 			typedef std::future<ModifyTopicRemarkOutcome> ModifyTopicRemarkOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::ModifyTopicRemarkRequest&, const ModifyTopicRemarkOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ModifyTopicRemarkAsyncHandler;
+			typedef Outcome<Error, Model::QueryMessageResult> QueryMessageOutcome;
+			typedef std::future<QueryMessageOutcome> QueryMessageOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::QueryMessageRequest&, const QueryMessageOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> QueryMessageAsyncHandler;
 			typedef Outcome<Error, Model::ReleaseInstanceResult> ReleaseInstanceOutcome;
 			typedef std::future<ReleaseInstanceOutcome> ReleaseInstanceOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::ReleaseInstanceRequest&, const ReleaseInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ReleaseInstanceAsyncHandler;
+			typedef Outcome<Error, Model::ReopenInstanceResult> ReopenInstanceOutcome;
+			typedef std::future<ReopenInstanceOutcome> ReopenInstanceOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::ReopenInstanceRequest&, const ReopenInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ReopenInstanceAsyncHandler;
 			typedef Outcome<Error, Model::StartInstanceResult> StartInstanceOutcome;
 			typedef std::future<StartInstanceOutcome> StartInstanceOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::StartInstanceRequest&, const StartInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> StartInstanceAsyncHandler;
+			typedef Outcome<Error, Model::StopInstanceResult> StopInstanceOutcome;
+			typedef std::future<StopInstanceOutcome> StopInstanceOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::StopInstanceRequest&, const StopInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> StopInstanceAsyncHandler;
 			typedef Outcome<Error, Model::TagResourcesResult> TagResourcesOutcome;
 			typedef std::future<TagResourcesOutcome> TagResourcesOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::TagResourcesRequest&, const TagResourcesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> TagResourcesAsyncHandler;
@@ -207,6 +239,9 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::UpdateInstanceConfigResult> UpdateInstanceConfigOutcome;
 			typedef std::future<UpdateInstanceConfigOutcome> UpdateInstanceConfigOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::UpdateInstanceConfigRequest&, const UpdateInstanceConfigOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> UpdateInstanceConfigAsyncHandler;
+			typedef Outcome<Error, Model::UpdateTopicConfigResult> UpdateTopicConfigOutcome;
+			typedef std::future<UpdateTopicConfigOutcome> UpdateTopicConfigOutcomeCallable;
+			typedef std::function<void(const AlikafkaClient*, const Model::UpdateTopicConfigRequest&, const UpdateTopicConfigOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> UpdateTopicConfigAsyncHandler;
 			typedef Outcome<Error, Model::UpgradeInstanceVersionResult> UpgradeInstanceVersionOutcome;
 			typedef std::future<UpgradeInstanceVersionOutcome> UpgradeInstanceVersionOutcomeCallable;
 			typedef std::function<void(const AlikafkaClient*, const Model::UpgradeInstanceVersionRequest&, const UpgradeInstanceVersionOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> UpgradeInstanceVersionAsyncHandler;
@@ -266,6 +301,12 @@ namespace AlibabaCloud
 			DescribeSaslUsersOutcome describeSaslUsers(const Model::DescribeSaslUsersRequest &request)const;
 			void describeSaslUsersAsync(const Model::DescribeSaslUsersRequest& request, const DescribeSaslUsersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			DescribeSaslUsersOutcomeCallable describeSaslUsersCallable(const Model::DescribeSaslUsersRequest& request) const;
+			EnableAutoGroupCreationOutcome enableAutoGroupCreation(const Model::EnableAutoGroupCreationRequest &request)const;
+			void enableAutoGroupCreationAsync(const Model::EnableAutoGroupCreationRequest& request, const EnableAutoGroupCreationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			EnableAutoGroupCreationOutcomeCallable enableAutoGroupCreationCallable(const Model::EnableAutoGroupCreationRequest& request) const;
+			EnableAutoTopicCreationOutcome enableAutoTopicCreation(const Model::EnableAutoTopicCreationRequest &request)const;
+			void enableAutoTopicCreationAsync(const Model::EnableAutoTopicCreationRequest& request, const EnableAutoTopicCreationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			EnableAutoTopicCreationOutcomeCallable enableAutoTopicCreationCallable(const Model::EnableAutoTopicCreationRequest& request) const;
 			GetAllInstanceIdListOutcome getAllInstanceIdList(const Model::GetAllInstanceIdListRequest &request)const;
 			void getAllInstanceIdListAsync(const Model::GetAllInstanceIdListRequest& request, const GetAllInstanceIdListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			GetAllInstanceIdListOutcomeCallable getAllInstanceIdListCallable(const Model::GetAllInstanceIdListRequest& request) const;
@@ -290,6 +331,9 @@ namespace AlibabaCloud
 			GetTopicStatusOutcome getTopicStatus(const Model::GetTopicStatusRequest &request)const;
 			void getTopicStatusAsync(const Model::GetTopicStatusRequest& request, const GetTopicStatusAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			GetTopicStatusOutcomeCallable getTopicStatusCallable(const Model::GetTopicStatusRequest& request) const;
+			GetTopicSubscribeStatusOutcome getTopicSubscribeStatus(const Model::GetTopicSubscribeStatusRequest &request)const;
+			void getTopicSubscribeStatusAsync(const Model::GetTopicSubscribeStatusRequest& request, const GetTopicSubscribeStatusAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			GetTopicSubscribeStatusOutcomeCallable getTopicSubscribeStatusCallable(const Model::GetTopicSubscribeStatusRequest& request) const;
 			ListTagResourcesOutcome listTagResources(const Model::ListTagResourcesRequest &request)const;
 			void listTagResourcesAsync(const Model::ListTagResourcesRequest& request, const ListTagResourcesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			ListTagResourcesOutcomeCallable listTagResourcesCallable(const Model::ListTagResourcesRequest& request) const;
@@ -302,12 +346,21 @@ namespace AlibabaCloud
 			ModifyTopicRemarkOutcome modifyTopicRemark(const Model::ModifyTopicRemarkRequest &request)const;
 			void modifyTopicRemarkAsync(const Model::ModifyTopicRemarkRequest& request, const ModifyTopicRemarkAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			ModifyTopicRemarkOutcomeCallable modifyTopicRemarkCallable(const Model::ModifyTopicRemarkRequest& request) const;
+			QueryMessageOutcome queryMessage(const Model::QueryMessageRequest &request)const;
+			void queryMessageAsync(const Model::QueryMessageRequest& request, const QueryMessageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			QueryMessageOutcomeCallable queryMessageCallable(const Model::QueryMessageRequest& request) const;
 			ReleaseInstanceOutcome releaseInstance(const Model::ReleaseInstanceRequest &request)const;
 			void releaseInstanceAsync(const Model::ReleaseInstanceRequest& request, const ReleaseInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			ReleaseInstanceOutcomeCallable releaseInstanceCallable(const Model::ReleaseInstanceRequest& request) const;
+			ReopenInstanceOutcome reopenInstance(const Model::ReopenInstanceRequest &request)const;
+			void reopenInstanceAsync(const Model::ReopenInstanceRequest& request, const ReopenInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			ReopenInstanceOutcomeCallable reopenInstanceCallable(const Model::ReopenInstanceRequest& request) const;
 			StartInstanceOutcome startInstance(const Model::StartInstanceRequest &request)const;
 			void startInstanceAsync(const Model::StartInstanceRequest& request, const StartInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			StartInstanceOutcomeCallable startInstanceCallable(const Model::StartInstanceRequest& request) const;
+			StopInstanceOutcome stopInstance(const Model::StopInstanceRequest &request)const;
+			void stopInstanceAsync(const Model::StopInstanceRequest& request, const StopInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			StopInstanceOutcomeCallable stopInstanceCallable(const Model::StopInstanceRequest& request) const;
 			TagResourcesOutcome tagResources(const Model::TagResourcesRequest &request)const;
 			void tagResourcesAsync(const Model::TagResourcesRequest& request, const TagResourcesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			TagResourcesOutcomeCallable tagResourcesCallable(const Model::TagResourcesRequest& request) const;
@@ -323,6 +376,9 @@ namespace AlibabaCloud
 			UpdateInstanceConfigOutcome updateInstanceConfig(const Model::UpdateInstanceConfigRequest &request)const;
 			void updateInstanceConfigAsync(const Model::UpdateInstanceConfigRequest& request, const UpdateInstanceConfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			UpdateInstanceConfigOutcomeCallable updateInstanceConfigCallable(const Model::UpdateInstanceConfigRequest& request) const;
+			UpdateTopicConfigOutcome updateTopicConfig(const Model::UpdateTopicConfigRequest &request)const;
+			void updateTopicConfigAsync(const Model::UpdateTopicConfigRequest& request, const UpdateTopicConfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			UpdateTopicConfigOutcomeCallable updateTopicConfigCallable(const Model::UpdateTopicConfigRequest& request) const;
 			UpgradeInstanceVersionOutcome upgradeInstanceVersion(const Model::UpgradeInstanceVersionRequest &request)const;
 			void upgradeInstanceVersionAsync(const Model::UpgradeInstanceVersionRequest& request, const UpgradeInstanceVersionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			UpgradeInstanceVersionOutcomeCallable upgradeInstanceVersionCallable(const Model::UpgradeInstanceVersionRequest& request) const;

alikafka/include/alibabacloud/alikafka/model/CreateAclRequest.h

@@ -34,6 +34,8 @@ public:
 	void setAclResourcePatternType(const std::string &aclResourcePatternType);
 	std::string getAclResourceType() const;
 	void setAclResourceType(const std::string &aclResourceType);
+	std::string getAclOperationTypes() const;
+	void setAclOperationTypes(const std::string &aclOperationTypes);
 	std::string getAclOperationType() const;
 	void setAclOperationType(const std::string &aclOperationType);
 	std::string getAclResourceName() const;
@@ -42,16 +44,23 @@ public:
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	std::string getHost() const;
+	void setHost(const std::string &host);
+	std::string getAclPermissionType() const;
+	void setAclPermissionType(const std::string &aclPermissionType);
 	std::string getUsername() const;
 	void setUsername(const std::string &username);
 
 private:
 	std::string aclResourcePatternType_;
 	std::string aclResourceType_;
+	std::string aclOperationTypes_;
 	std::string aclOperationType_;
 	std::string aclResourceName_;
 	std::string instanceId_;
 	std::string regionId_;
+	std::string host_;
+	std::string aclPermissionType_;
 	std::string username_;
 };
 } // namespace Model

alikafka/include/alibabacloud/alikafka/model/CreatePrePayOrderRequest.h

@@ -28,6 +28,26 @@ namespace Alikafka {
 namespace Model {
 class ALIBABACLOUD_ALIKAFKA_EXPORT CreatePrePayOrderRequest : public RpcServiceRequest {
 public:
+	struct ConfluentConfig {
+		int ksqlStorage;
+		int controlCenterStorage;
+		int kafkaRestProxyReplica;
+		int zooKeeperReplica;
+		int connectCU;
+		int kafkaReplica;
+		int schemaRegistryReplica;
+		int kafkaCU;
+		int connectReplica;
+		int controlCenterCU;
+		int ksqlReplica;
+		int controlCenterReplica;
+		int kafkaStorage;
+		int zooKeeperStorage;
+		int ksqlCU;
+		int schemaRegistryCU;
+		int zooKeeperCU;
+		int kafkaRestProxyCU;
+	};
 	struct Tag {
 		std::string value;
 		std::string key;
@@ -38,16 +58,22 @@ public:
 	void setIoMax(int ioMax);
 	int getEipMax() const;
 	void setEipMax(int eipMax);
+	int getDuration() const;
+	void setDuration(int duration);
 	std::string getSpecType() const;
 	void setSpecType(const std::string &specType);
 	std::string getResourceGroupId() const;
 	void setResourceGroupId(const std::string &resourceGroupId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	ConfluentConfig getConfluentConfig() const;
+	void setConfluentConfig(const ConfluentConfig &confluentConfig);
 	std::vector<Tag> getTag() const;
 	void setTag(const std::vector<Tag> &tag);
 	int getPartitionNum() const;
 	void setPartitionNum(int partitionNum);
+	int getPaidType() const;
+	void setPaidType(int paidType);
 	int getDiskSize() const;
 	void setDiskSize(int diskSize);
 	std::string getIoMaxSpec() const;
@@ -62,11 +88,14 @@ public:
 private:
 	int ioMax_;
 	int eipMax_;
+	int duration_;
 	std::string specType_;
 	std::string resourceGroupId_;
 	std::string regionId_;
+	ConfluentConfig confluentConfig_;
 	std::vector<Tag> tag_;
 	int partitionNum_;
+	int paidType_;
 	int diskSize_;
 	std::string ioMaxSpec_;
 	std::string diskType_;

alikafka/include/alibabacloud/alikafka/model/CreateSaslUserRequest.h

@@ -38,6 +38,8 @@ public:
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	std::string getMechanism() const;
+	void setMechanism(const std::string &mechanism);
 	std::string getUsername() const;
 	void setUsername(const std::string &username);
 
@@ -46,6 +48,7 @@ private:
 	std::string password_;
 	std::string instanceId_;
 	std::string regionId_;
+	std::string mechanism_;
 	std::string username_;
 };
 } // namespace Model

alikafka/include/alibabacloud/alikafka/model/DeleteAclRequest.h

@@ -34,6 +34,8 @@ public:
 	void setAclResourcePatternType(const std::string &aclResourcePatternType);
 	std::string getAclResourceType() const;
 	void setAclResourceType(const std::string &aclResourceType);
+	std::string getAclOperationTypes() const;
+	void setAclOperationTypes(const std::string &aclOperationTypes);
 	std::string getAclOperationType() const;
 	void setAclOperationType(const std::string &aclOperationType);
 	std::string getAclResourceName() const;
@@ -42,16 +44,23 @@ public:
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	std::string getHost() const;
+	void setHost(const std::string &host);
+	std::string getAclPermissionType() const;
+	void setAclPermissionType(const std::string &aclPermissionType);
 	std::string getUsername() const;
 	void setUsername(const std::string &username);
 
 private:
 	std::string aclResourcePatternType_;
 	std::string aclResourceType_;
+	std::string aclOperationTypes_;
 	std::string aclOperationType_;
 	std::string aclResourceName_;
 	std::string instanceId_;
 	std::string regionId_;
+	std::string host_;
+	std::string aclPermissionType_;
 	std::string username_;
 };
 } // namespace Model

alikafka/include/alibabacloud/alikafka/model/DeleteSaslUserRequest.h

@@ -36,6 +36,8 @@ public:
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	std::string getMechanism() const;
+	void setMechanism(const std::string &mechanism);
 	std::string getUsername() const;
 	void setUsername(const std::string &username);
 
@@ -43,6 +45,7 @@ private:
 	std::string type_;
 	std::string instanceId_;
 	std::string regionId_;
+	std::string mechanism_;
 	std::string username_;
 };
 } // namespace Model

alikafka/include/alibabacloud/alikafka/model/DescribeAclsRequest.h

@@ -34,21 +34,30 @@ public:
 	void setAclResourcePatternType(const std::string &aclResourcePatternType);
 	std::string getAclResourceType() const;
 	void setAclResourceType(const std::string &aclResourceType);
+	std::string getAclOperationType() const;
+	void setAclOperationType(const std::string &aclOperationType);
 	std::string getAclResourceName() const;
 	void setAclResourceName(const std::string &aclResourceName);
 	std::string getInstanceId() const;
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	std::string getHost() const;
+	void setHost(const std::string &host);
+	std::string getAclPermissionType() const;
+	void setAclPermissionType(const std::string &aclPermissionType);
 	std::string getUsername() const;
 	void setUsername(const std::string &username);
 
 private:
 	std::string aclResourcePatternType_;
 	std::string aclResourceType_;
+	std::string aclOperationType_;
 	std::string aclResourceName_;
 	std::string instanceId_;
 	std::string regionId_;
+	std::string host_;
+	std::string aclPermissionType_;
 	std::string username_;
 };
 } // namespace Model

alikafka/include/alibabacloud/alikafka/model/DescribeAclsResult.h

@@ -38,6 +38,7 @@ namespace AlibabaCloud
 					std::string username;
 					std::string aclResourceType;
 					std::string aclOperationType;
+					std::string aclPermissionType;
 					std::string host;
 					std::string aclResourcePatternType;
 				};

alikafka/include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h

@@ -36,6 +36,7 @@ namespace AlibabaCloud
 				{
 					std::string type;
 					std::string username;
+					std::string mechanism;
 					std::string password;
 				};
 

alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoGroupCreationRequest : public RpcServiceRequest {
+public:
+	EnableAutoGroupCreationRequest();
+	~EnableAutoGroupCreationRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+	bool getEnable() const;
+	void setEnable(bool enable);
+
+private:
+	std::string instanceId_;
+	std::string regionId_;
+	bool enable_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoGroupCreationResult : public ServiceResult
+			{
+			public:
+
+
+				EnableAutoGroupCreationResult();
+				explicit EnableAutoGroupCreationResult(const std::string &payload);
+				~EnableAutoGroupCreationResult();
+				std::string getMessage()const;
+				int getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				int code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_

alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h

@@ -0,0 +1,51 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoTopicCreationRequest : public RpcServiceRequest {
+public:
+	EnableAutoTopicCreationRequest();
+	~EnableAutoTopicCreationRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getOperate() const;
+	void setOperate(const std::string &operate);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+	long getPartitionNum() const;
+	void setPartitionNum(long partitionNum);
+
+private:
+	std::string instanceId_;
+	std::string operate_;
+	std::string regionId_;
+	long partitionNum_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoTopicCreationResult : public ServiceResult
+			{
+			public:
+
+
+				EnableAutoTopicCreationResult();
+				explicit EnableAutoTopicCreationResult(const std::string &payload);
+				~EnableAutoTopicCreationResult();
+				std::string getMessage()const;
+				int getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				int code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_

alikafka/include/alibabacloud/alikafka/model/GetConsumerListResult.h

@@ -52,6 +52,9 @@ namespace AlibabaCloud
 				explicit GetConsumerListResult(const std::string &payload);
 				~GetConsumerListResult();
 				std::string getMessage()const;
+				int getPageSize()const;
+				int getCurrentPage()const;
+				long getTotal()const;
 				std::vector<ConsumerVO> getConsumerList()const;
 				int getCode()const;
 				bool getSuccess()const;
@@ -60,6 +63,9 @@ namespace AlibabaCloud
 				void parse(const std::string &payload);
 			private:
 				std::string message_;
+				int pageSize_;
+				int currentPage_;
+				long total_;
 				std::vector<ConsumerVO> consumerList_;
 				int code_;
 				bool success_;

alikafka/include/alibabacloud/alikafka/model/GetConsumerProgressResult.h

@@ -48,6 +48,16 @@ namespace AlibabaCloud
 						long totalDiff;
 						std::string topic;
 					};
+					struct RebalanceInfoListItem
+					{
+						bool rebalanceSuccess;
+						long generation;
+						long rebalanceTimeConsuming;
+						long lastRebalanceTimestamp;
+						std::string reason;
+						std::string groupId;
+					};
+					std::vector<RebalanceInfoListItem> rebalanceInfoList;
 					long lastTimestamp;
 					std::vector<TopicListItem> topicList;
 					long totalDiff;

alikafka/include/alibabacloud/alikafka/model/GetInstanceListResult.h

@@ -38,12 +38,34 @@ namespace AlibabaCloud
 					{
 						std::string current2OpenSourceVersion;
 					};
+					struct ConfluentConfig
+					{
+						int ksqlStorage;
+						int kafkaRestProxyCU;
+						int zooKeeperReplica;
+						int kafkaReplica;
+						int connectReplica;
+						int controlCenterStorage;
+						int schemaRegistryCU;
+						int kafkaCU;
+						int connectCU;
+						int ksqlCU;
+						int controlCenterReplica;
+						int ksqlReplica;
+						int schemaRegistryReplica;
+						int zooKeeperCU;
+						int kafkaRestProxyReplica;
+						int zooKeeperStorage;
+						int controlCenterCU;
+						int kafkaStorage;
+					};
 					struct TagVO
 					{
 						std::string value;
 						std::string key;
 					};
 					int deployType;
+					int reservedPublishCapacity;
 					std::string resourceGroupId;
 					std::string specType;
 					int ioMax;
@@ -52,9 +74,12 @@ namespace AlibabaCloud
 					UpgradeServiceDetailInfo upgradeServiceDetailInfo;
 					std::string saslDomainEndpoint;
 					std::string name;
+					int viewInstanceStatusCode;
+					ConfluentConfig confluentConfig;
 					int diskType;
 					std::string sslDomainEndpoint;
 					int serviceStatus;
+					int reservedSubscribeCapacity;
 					int msgRetain;
 					long expiredTime;
 					int diskSize;

alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT GetTopicSubscribeStatusRequest : public RpcServiceRequest {
+public:
+	GetTopicSubscribeStatusRequest();
+	~GetTopicSubscribeStatusRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+	std::string getTopic() const;
+	void setTopic(const std::string &topic);
+
+private:
+	std::string instanceId_;
+	std::string regionId_;
+	std::string topic_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT GetTopicSubscribeStatusResult : public ServiceResult
+			{
+			public:
+				struct TopicSubscribeStatus
+				{
+					std::vector<std::string> consumerGroups;
+					std::string topic;
+				};
+
+
+				GetTopicSubscribeStatusResult();
+				explicit GetTopicSubscribeStatusResult(const std::string &payload);
+				~GetTopicSubscribeStatusResult();
+				std::string getMessage()const;
+				TopicSubscribeStatus getTopicSubscribeStatus()const;
+				int getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				TopicSubscribeStatus topicSubscribeStatus_;
+				int code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_

alikafka/include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h

@@ -30,20 +30,20 @@ class ALIBABACLOUD_ALIKAFKA_EXPORT ModifyTopicRemarkRequest : public RpcServiceR
 public:
 	ModifyTopicRemarkRequest();
 	~ModifyTopicRemarkRequest();
+	std::string getRemark() const;
+	void setRemark(const std::string &remark);
 	std::string getInstanceId() const;
 	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
 	std::string getTopic() const;
 	void setTopic(const std::string &topic);
-	std::string getRemark() const;
-	void setRemark(const std::string &remark);
 
 private:
+	std::string remark_;
 	std::string instanceId_;
 	std::string regionId_;
 	std::string topic_;
-	std::string remark_;
 };
 } // namespace Model
 } // namespace Alikafka

alikafka/include/alibabacloud/alikafka/model/QueryMessageRequest.h

@@ -0,0 +1,60 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT QueryMessageRequest : public RpcServiceRequest {
+public:
+	QueryMessageRequest();
+	~QueryMessageRequest();
+	std::string getOffset() const;
+	void setOffset(const std::string &offset);
+	long getBeginTime() const;
+	void setBeginTime(long beginTime);
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getPartition() const;
+	void setPartition(const std::string &partition);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+	std::string getTopic() const;
+	void setTopic(const std::string &topic);
+	std::string getQueryType() const;
+	void setQueryType(const std::string &queryType);
+
+private:
+	std::string offset_;
+	long beginTime_;
+	std::string instanceId_;
+	std::string partition_;
+	std::string regionId_;
+	std::string topic_;
+	std::string queryType_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/QueryMessageResult.h

@@ -0,0 +1,74 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT QueryMessageResult : public ServiceResult
+			{
+			public:
+				struct MessageVO
+				{
+					long partition;
+					int truncatedValueSize;
+					bool valueTruncated;
+					long timestamp;
+					long offset;
+					int truncatedKeySize;
+					long checksum;
+					int serializedValueSize;
+					std::string value;
+					std::string timestampType;
+					bool keyTruncated;
+					std::string topic;
+					std::string key;
+					int serializedKeySize;
+				};
+
+
+				QueryMessageResult();
+				explicit QueryMessageResult(const std::string &payload);
+				~QueryMessageResult();
+				std::string getMessage()const;
+				int getCode()const;
+				std::vector<MessageVO> getMessageList()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				int code_;
+				std::vector<MessageVO> messageList_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_

alikafka/include/alibabacloud/alikafka/model/ReopenInstanceRequest.h

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT ReopenInstanceRequest : public RpcServiceRequest {
+public:
+	ReopenInstanceRequest();
+	~ReopenInstanceRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+
+private:
+	std::string instanceId_;
+	std::string regionId_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/ReopenInstanceResult.h

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT ReopenInstanceResult : public ServiceResult
+			{
+			public:
+
+
+				ReopenInstanceResult();
+				explicit ReopenInstanceResult(const std::string &payload);
+				~ReopenInstanceResult();
+				std::string getMessage()const;
+				int getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				int code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_

alikafka/include/alibabacloud/alikafka/model/StartInstanceRequest.h

@@ -30,6 +30,8 @@ class ALIBABACLOUD_ALIKAFKA_EXPORT StartInstanceRequest : public RpcServiceReque
 public:
 	StartInstanceRequest();
 	~StartInstanceRequest();
+	std::vector<std::string> getVSwitchIds() const;
+	void setVSwitchIds(const std::vector<std::string> &vSwitchIds);
 	std::string getSelectedZones() const;
 	void setSelectedZones(const std::string &selectedZones);
 	bool getIsEipInner() const;
@@ -72,6 +74,7 @@ public:
 	void setUsername(const std::string &username);
 
 private:
+	std::vector<std::string> vSwitchIds_;
 	std::string selectedZones_;
 	bool isEipInner_;
 	std::string securityGroup_;

alikafka/include/alibabacloud/alikafka/model/StopInstanceRequest.h

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT StopInstanceRequest : public RpcServiceRequest {
+public:
+	StopInstanceRequest();
+	~StopInstanceRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+
+private:
+	std::string instanceId_;
+	std::string regionId_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/StopInstanceResult.h

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT StopInstanceResult : public ServiceResult
+			{
+			public:
+
+
+				StopInstanceResult();
+				explicit StopInstanceResult(const std::string &payload);
+				~StopInstanceResult();
+				std::string getMessage()const;
+				int getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				int code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_

alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_
+
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace Alikafka {
+namespace Model {
+class ALIBABACLOUD_ALIKAFKA_EXPORT UpdateTopicConfigRequest : public RpcServiceRequest {
+public:
+	UpdateTopicConfigRequest();
+	~UpdateTopicConfigRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getRegionId() const;
+	void setRegionId(const std::string &regionId);
+	std::string getTopic() const;
+	void setTopic(const std::string &topic);
+	std::string getConfig() const;
+	void setConfig(const std::string &config);
+	std::string getValue() const;
+	void setValue(const std::string &value);
+
+private:
+	std::string instanceId_;
+	std::string regionId_;
+	std::string topic_;
+	std::string config_;
+	std::string value_;
+};
+} // namespace Model
+} // namespace Alikafka
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_

alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_
+#define ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/alikafka/AlikafkaExport.h>
+
+namespace AlibabaCloud
+{
+	namespace Alikafka
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_ALIKAFKA_EXPORT UpdateTopicConfigResult : public ServiceResult
+			{
+			public:
+
+
+				UpdateTopicConfigResult();
+				explicit UpdateTopicConfigResult(const std::string &payload);
+				~UpdateTopicConfigResult();
+				std::string getMessage()const;
+				std::string getData()const;
+				long getCode()const;
+				bool getSuccess()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::string message_;
+				std::string data_;
+				long code_;
+				bool success_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_

alikafka/include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h

@@ -28,8 +28,14 @@ namespace Alikafka {
 namespace Model {
 class ALIBABACLOUD_ALIKAFKA_EXPORT UpgradePostPayOrderRequest : public RpcServiceRequest {
 public:
+	struct ServerlessConfig {
+		long reservedPublishCapacity;
+		long reservedSubscribeCapacity;
+	};
 	UpgradePostPayOrderRequest();
 	~UpgradePostPayOrderRequest();
+	ServerlessConfig getServerlessConfig() const;
+	void setServerlessConfig(const ServerlessConfig &serverlessConfig);
 	int getDiskSize() const;
 	void setDiskSize(int diskSize);
 	int getIoMax() const;
@@ -52,6 +58,7 @@ public:
 	void setPartitionNum(int partitionNum);
 
 private:
+	ServerlessConfig serverlessConfig_;
 	int diskSize_;
 	int ioMax_;
 	bool eipModel_;

alikafka/include/alibabacloud/alikafka/model/UpgradePrePayOrderRequest.h

@@ -28,40 +28,66 @@ namespace Alikafka {
 namespace Model {
 class ALIBABACLOUD_ALIKAFKA_EXPORT UpgradePrePayOrderRequest : public RpcServiceRequest {
 public:
+	struct ConfluentConfig {
+		int ksqlStorage;
+		int controlCenterStorage;
+		int kafkaRestProxyReplica;
+		int zooKeeperReplica;
+		int connectCU;
+		int kafkaReplica;
+		int schemaRegistryReplica;
+		int kafkaCU;
+		int connectReplica;
+		int controlCenterCU;
+		int ksqlReplica;
+		int controlCenterReplica;
+		int kafkaStorage;
+		int zooKeeperStorage;
+		int ksqlCU;
+		int schemaRegistryCU;
+		int zooKeeperCU;
+		int kafkaRestProxyCU;
+	};
 	UpgradePrePayOrderRequest();
 	~UpgradePrePayOrderRequest();
-	int getDiskSize() const;
-	void setDiskSize(int diskSize);
 	int getIoMax() const;
 	void setIoMax(int ioMax);
 	bool getEipModel() const;
 	void setEipModel(bool eipModel);
-	std::string getIoMaxSpec() const;
-	void setIoMaxSpec(const std::string &ioMaxSpec);
-	int getTopicQuota() const;
-	void setTopicQuota(int topicQuota);
 	int getEipMax() const;
 	void setEipMax(int eipMax);
 	std::string getSpecType() const;
 	void setSpecType(const std::string &specType);
-	std::string getInstanceId() const;
-	void setInstanceId(const std::string &instanceId);
 	std::string getRegionId() const;
 	void setRegionId(const std::string &regionId);
+	ConfluentConfig getConfluentConfig() const;
+	void setConfluentConfig(const ConfluentConfig &confluentConfig);
 	int getPartitionNum() const;
 	void setPartitionNum(int partitionNum);
+	int getPaidType() const;
+	void setPaidType(int paidType);
+	int getDiskSize() const;
+	void setDiskSize(int diskSize);
+	std::string getIoMaxSpec() const;
+	void setIoMaxSpec(const std::string &ioMaxSpec);
+	int getTopicQuota() const;
+	void setTopicQuota(int topicQuota);
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
 
 private:
-	int diskSize_;
 	int ioMax_;
 	bool eipModel_;
-	std::string ioMaxSpec_;
-	int topicQuota_;
 	int eipMax_;
 	std::string specType_;
-	std::string instanceId_;
 	std::string regionId_;
+	ConfluentConfig confluentConfig_;
 	int partitionNum_;
+	int paidType_;
+	int diskSize_;
+	std::string ioMaxSpec_;
+	int topicQuota_;
+	std::string instanceId_;
 };
 } // namespace Model
 } // namespace Alikafka

alikafka/src/AlikafkaClient.cc

@@ -31,21 +31,21 @@ AlikafkaClient::AlikafkaClient(const Credentials &credentials, const ClientConfi
 	RpcServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(credentials), configuration)
 {
 	auto locationClient = std::make_shared<LocationClient>(credentials, configuration);
-	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
+	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka");
 }
 
 AlikafkaClient::AlikafkaClient(const std::shared_ptr<CredentialsProvider>& credentialsProvider, const ClientConfiguration & configuration) :
 	RpcServiceClient(SERVICE_NAME, credentialsProvider, configuration)
 {
 	auto locationClient = std::make_shared<LocationClient>(credentialsProvider, configuration);
-	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
+	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka");
 }
 
 AlikafkaClient::AlikafkaClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) :
 	RpcServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(accessKeyId, accessKeySecret), configuration)
 {
 	auto locationClient = std::make_shared<LocationClient>(accessKeyId, accessKeySecret, configuration);
-	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
+	endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka");
 }
 
 AlikafkaClient::~AlikafkaClient()
@@ -591,6 +591,78 @@ AlikafkaClient::DescribeSaslUsersOutcomeCallable AlikafkaClient::describeSaslUse
 	return task->get_future();
 }
 
+AlikafkaClient::EnableAutoGroupCreationOutcome AlikafkaClient::enableAutoGroupCreation(const EnableAutoGroupCreationRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return EnableAutoGroupCreationOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return EnableAutoGroupCreationOutcome(EnableAutoGroupCreationResult(outcome.result()));
+	else
+		return EnableAutoGroupCreationOutcome(outcome.error());
+}
+
+void AlikafkaClient::enableAutoGroupCreationAsync(const EnableAutoGroupCreationRequest& request, const EnableAutoGroupCreationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, enableAutoGroupCreation(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::EnableAutoGroupCreationOutcomeCallable AlikafkaClient::enableAutoGroupCreationCallable(const EnableAutoGroupCreationRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<EnableAutoGroupCreationOutcome()>>(
+			[this, request]()
+			{
+			return this->enableAutoGroupCreation(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
+AlikafkaClient::EnableAutoTopicCreationOutcome AlikafkaClient::enableAutoTopicCreation(const EnableAutoTopicCreationRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return EnableAutoTopicCreationOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return EnableAutoTopicCreationOutcome(EnableAutoTopicCreationResult(outcome.result()));
+	else
+		return EnableAutoTopicCreationOutcome(outcome.error());
+}
+
+void AlikafkaClient::enableAutoTopicCreationAsync(const EnableAutoTopicCreationRequest& request, const EnableAutoTopicCreationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, enableAutoTopicCreation(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::EnableAutoTopicCreationOutcomeCallable AlikafkaClient::enableAutoTopicCreationCallable(const EnableAutoTopicCreationRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<EnableAutoTopicCreationOutcome()>>(
+			[this, request]()
+			{
+			return this->enableAutoTopicCreation(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::GetAllInstanceIdListOutcome AlikafkaClient::getAllInstanceIdList(const GetAllInstanceIdListRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -879,6 +951,42 @@ AlikafkaClient::GetTopicStatusOutcomeCallable AlikafkaClient::getTopicStatusCall
 	return task->get_future();
 }
 
+AlikafkaClient::GetTopicSubscribeStatusOutcome AlikafkaClient::getTopicSubscribeStatus(const GetTopicSubscribeStatusRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return GetTopicSubscribeStatusOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return GetTopicSubscribeStatusOutcome(GetTopicSubscribeStatusResult(outcome.result()));
+	else
+		return GetTopicSubscribeStatusOutcome(outcome.error());
+}
+
+void AlikafkaClient::getTopicSubscribeStatusAsync(const GetTopicSubscribeStatusRequest& request, const GetTopicSubscribeStatusAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, getTopicSubscribeStatus(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::GetTopicSubscribeStatusOutcomeCallable AlikafkaClient::getTopicSubscribeStatusCallable(const GetTopicSubscribeStatusRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<GetTopicSubscribeStatusOutcome()>>(
+			[this, request]()
+			{
+			return this->getTopicSubscribeStatus(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::ListTagResourcesOutcome AlikafkaClient::listTagResources(const ListTagResourcesRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1023,6 +1131,42 @@ AlikafkaClient::ModifyTopicRemarkOutcomeCallable AlikafkaClient::modifyTopicRema
 	return task->get_future();
 }
 
+AlikafkaClient::QueryMessageOutcome AlikafkaClient::queryMessage(const QueryMessageRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return QueryMessageOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return QueryMessageOutcome(QueryMessageResult(outcome.result()));
+	else
+		return QueryMessageOutcome(outcome.error());
+}
+
+void AlikafkaClient::queryMessageAsync(const QueryMessageRequest& request, const QueryMessageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, queryMessage(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::QueryMessageOutcomeCallable AlikafkaClient::queryMessageCallable(const QueryMessageRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<QueryMessageOutcome()>>(
+			[this, request]()
+			{
+			return this->queryMessage(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::ReleaseInstanceOutcome AlikafkaClient::releaseInstance(const ReleaseInstanceRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1059,6 +1203,42 @@ AlikafkaClient::ReleaseInstanceOutcomeCallable AlikafkaClient::releaseInstanceCa
 	return task->get_future();
 }
 
+AlikafkaClient::ReopenInstanceOutcome AlikafkaClient::reopenInstance(const ReopenInstanceRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return ReopenInstanceOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return ReopenInstanceOutcome(ReopenInstanceResult(outcome.result()));
+	else
+		return ReopenInstanceOutcome(outcome.error());
+}
+
+void AlikafkaClient::reopenInstanceAsync(const ReopenInstanceRequest& request, const ReopenInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, reopenInstance(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::ReopenInstanceOutcomeCallable AlikafkaClient::reopenInstanceCallable(const ReopenInstanceRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<ReopenInstanceOutcome()>>(
+			[this, request]()
+			{
+			return this->reopenInstance(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::StartInstanceOutcome AlikafkaClient::startInstance(const StartInstanceRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1095,6 +1275,42 @@ AlikafkaClient::StartInstanceOutcomeCallable AlikafkaClient::startInstanceCallab
 	return task->get_future();
 }
 
+AlikafkaClient::StopInstanceOutcome AlikafkaClient::stopInstance(const StopInstanceRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return StopInstanceOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return StopInstanceOutcome(StopInstanceResult(outcome.result()));
+	else
+		return StopInstanceOutcome(outcome.error());
+}
+
+void AlikafkaClient::stopInstanceAsync(const StopInstanceRequest& request, const StopInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, stopInstance(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::StopInstanceOutcomeCallable AlikafkaClient::stopInstanceCallable(const StopInstanceRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<StopInstanceOutcome()>>(
+			[this, request]()
+			{
+			return this->stopInstance(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::TagResourcesOutcome AlikafkaClient::tagResources(const TagResourcesRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1275,6 +1491,42 @@ AlikafkaClient::UpdateInstanceConfigOutcomeCallable AlikafkaClient::updateInstan
 	return task->get_future();
 }
 
+AlikafkaClient::UpdateTopicConfigOutcome AlikafkaClient::updateTopicConfig(const UpdateTopicConfigRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return UpdateTopicConfigOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return UpdateTopicConfigOutcome(UpdateTopicConfigResult(outcome.result()));
+	else
+		return UpdateTopicConfigOutcome(outcome.error());
+}
+
+void AlikafkaClient::updateTopicConfigAsync(const UpdateTopicConfigRequest& request, const UpdateTopicConfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, updateTopicConfig(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+AlikafkaClient::UpdateTopicConfigOutcomeCallable AlikafkaClient::updateTopicConfigCallable(const UpdateTopicConfigRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<UpdateTopicConfigOutcome()>>(
+			[this, request]()
+			{
+			return this->updateTopicConfig(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 AlikafkaClient::UpgradeInstanceVersionOutcome AlikafkaClient::upgradeInstanceVersion(const UpgradeInstanceVersionRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();

alikafka/src/model/CreateAclRequest.cc

@@ -43,6 +43,15 @@ void CreateAclRequest::setAclResourceType(const std::string &aclResourceType) {
   setParameter(std::string("AclResourceType"), aclResourceType);
 }
 
+std::string CreateAclRequest::getAclOperationTypes() const {
+  return aclOperationTypes_;
+}
+
+void CreateAclRequest::setAclOperationTypes(const std::string &aclOperationTypes) {
+  aclOperationTypes_ = aclOperationTypes;
+  setParameter(std::string("AclOperationTypes"), aclOperationTypes);
+}
+
 std::string CreateAclRequest::getAclOperationType() const {
   return aclOperationType_;
 }
@@ -79,6 +88,24 @@ void CreateAclRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+std::string CreateAclRequest::getHost() const {
+  return host_;
+}
+
+void CreateAclRequest::setHost(const std::string &host) {
+  host_ = host;
+  setParameter(std::string("Host"), host);
+}
+
+std::string CreateAclRequest::getAclPermissionType() const {
+  return aclPermissionType_;
+}
+
+void CreateAclRequest::setAclPermissionType(const std::string &aclPermissionType) {
+  aclPermissionType_ = aclPermissionType;
+  setParameter(std::string("AclPermissionType"), aclPermissionType);
+}
+
 std::string CreateAclRequest::getUsername() const {
   return username_;
 }

alikafka/src/model/CreatePrePayOrderRequest.cc

@@ -43,6 +43,15 @@ void CreatePrePayOrderRequest::setEipMax(int eipMax) {
   setParameter(std::string("EipMax"), std::to_string(eipMax));
 }
 
+int CreatePrePayOrderRequest::getDuration() const {
+  return duration_;
+}
+
+void CreatePrePayOrderRequest::setDuration(int duration) {
+  duration_ = duration;
+  setParameter(std::string("Duration"), std::to_string(duration));
+}
+
 std::string CreatePrePayOrderRequest::getSpecType() const {
   return specType_;
 }
@@ -70,6 +79,32 @@ void CreatePrePayOrderRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+CreatePrePayOrderRequest::ConfluentConfig CreatePrePayOrderRequest::getConfluentConfig() const {
+  return confluentConfig_;
+}
+
+void CreatePrePayOrderRequest::setConfluentConfig(const CreatePrePayOrderRequest::ConfluentConfig &confluentConfig) {
+  confluentConfig_ = confluentConfig;
+  setParameter(std::string("ConfluentConfig") + ".KsqlStorage", std::to_string(confluentConfig.ksqlStorage));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterStorage", std::to_string(confluentConfig.controlCenterStorage));
+  setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyReplica", std::to_string(confluentConfig.kafkaRestProxyReplica));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperReplica", std::to_string(confluentConfig.zooKeeperReplica));
+  setParameter(std::string("ConfluentConfig") + ".ConnectCU", std::to_string(confluentConfig.connectCU));
+  setParameter(std::string("ConfluentConfig") + ".KafkaReplica", std::to_string(confluentConfig.kafkaReplica));
+  setParameter(std::string("ConfluentConfig") + ".SchemaRegistryReplica", std::to_string(confluentConfig.schemaRegistryReplica));
+  setParameter(std::string("ConfluentConfig") + ".KafkaCU", std::to_string(confluentConfig.kafkaCU));
+  setParameter(std::string("ConfluentConfig") + ".ConnectReplica", std::to_string(confluentConfig.connectReplica));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterCU", std::to_string(confluentConfig.controlCenterCU));
+  setParameter(std::string("ConfluentConfig") + ".KsqlReplica", std::to_string(confluentConfig.ksqlReplica));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterReplica", std::to_string(confluentConfig.controlCenterReplica));
+  setParameter(std::string("ConfluentConfig") + ".KafkaStorage", std::to_string(confluentConfig.kafkaStorage));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperStorage", std::to_string(confluentConfig.zooKeeperStorage));
+  setParameter(std::string("ConfluentConfig") + ".KsqlCU", std::to_string(confluentConfig.ksqlCU));
+  setParameter(std::string("ConfluentConfig") + ".SchemaRegistryCU", std::to_string(confluentConfig.schemaRegistryCU));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperCU", std::to_string(confluentConfig.zooKeeperCU));
+  setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyCU", std::to_string(confluentConfig.kafkaRestProxyCU));
+}
+
 std::vector<CreatePrePayOrderRequest::Tag> CreatePrePayOrderRequest::getTag() const {
   return tag_;
 }
@@ -93,6 +128,15 @@ void CreatePrePayOrderRequest::setPartitionNum(int partitionNum) {
   setParameter(std::string("PartitionNum"), std::to_string(partitionNum));
 }
 
+int CreatePrePayOrderRequest::getPaidType() const {
+  return paidType_;
+}
+
+void CreatePrePayOrderRequest::setPaidType(int paidType) {
+  paidType_ = paidType;
+  setParameter(std::string("PaidType"), std::to_string(paidType));
+}
+
 int CreatePrePayOrderRequest::getDiskSize() const {
   return diskSize_;
 }

alikafka/src/model/CreateSaslUserRequest.cc

@@ -61,6 +61,15 @@ void CreateSaslUserRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+std::string CreateSaslUserRequest::getMechanism() const {
+  return mechanism_;
+}
+
+void CreateSaslUserRequest::setMechanism(const std::string &mechanism) {
+  mechanism_ = mechanism;
+  setParameter(std::string("Mechanism"), mechanism);
+}
+
 std::string CreateSaslUserRequest::getUsername() const {
   return username_;
 }

alikafka/src/model/DeleteAclRequest.cc

@@ -43,6 +43,15 @@ void DeleteAclRequest::setAclResourceType(const std::string &aclResourceType) {
   setParameter(std::string("AclResourceType"), aclResourceType);
 }
 
+std::string DeleteAclRequest::getAclOperationTypes() const {
+  return aclOperationTypes_;
+}
+
+void DeleteAclRequest::setAclOperationTypes(const std::string &aclOperationTypes) {
+  aclOperationTypes_ = aclOperationTypes;
+  setParameter(std::string("AclOperationTypes"), aclOperationTypes);
+}
+
 std::string DeleteAclRequest::getAclOperationType() const {
   return aclOperationType_;
 }
@@ -79,6 +88,24 @@ void DeleteAclRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+std::string DeleteAclRequest::getHost() const {
+  return host_;
+}
+
+void DeleteAclRequest::setHost(const std::string &host) {
+  host_ = host;
+  setParameter(std::string("Host"), host);
+}
+
+std::string DeleteAclRequest::getAclPermissionType() const {
+  return aclPermissionType_;
+}
+
+void DeleteAclRequest::setAclPermissionType(const std::string &aclPermissionType) {
+  aclPermissionType_ = aclPermissionType;
+  setParameter(std::string("AclPermissionType"), aclPermissionType);
+}
+
 std::string DeleteAclRequest::getUsername() const {
   return username_;
 }

alikafka/src/model/DeleteSaslUserRequest.cc

@@ -52,6 +52,15 @@ void DeleteSaslUserRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+std::string DeleteSaslUserRequest::getMechanism() const {
+  return mechanism_;
+}
+
+void DeleteSaslUserRequest::setMechanism(const std::string &mechanism) {
+  mechanism_ = mechanism;
+  setParameter(std::string("Mechanism"), mechanism);
+}
+
 std::string DeleteSaslUserRequest::getUsername() const {
   return username_;
 }

alikafka/src/model/DescribeAclsRequest.cc

@@ -43,6 +43,15 @@ void DescribeAclsRequest::setAclResourceType(const std::string &aclResourceType)
   setParameter(std::string("AclResourceType"), aclResourceType);
 }
 
+std::string DescribeAclsRequest::getAclOperationType() const {
+  return aclOperationType_;
+}
+
+void DescribeAclsRequest::setAclOperationType(const std::string &aclOperationType) {
+  aclOperationType_ = aclOperationType;
+  setParameter(std::string("AclOperationType"), aclOperationType);
+}
+
 std::string DescribeAclsRequest::getAclResourceName() const {
   return aclResourceName_;
 }
@@ -70,6 +79,24 @@ void DescribeAclsRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+std::string DescribeAclsRequest::getHost() const {
+  return host_;
+}
+
+void DescribeAclsRequest::setHost(const std::string &host) {
+  host_ = host;
+  setParameter(std::string("Host"), host);
+}
+
+std::string DescribeAclsRequest::getAclPermissionType() const {
+  return aclPermissionType_;
+}
+
+void DescribeAclsRequest::setAclPermissionType(const std::string &aclPermissionType) {
+  aclPermissionType_ = aclPermissionType;
+  setParameter(std::string("AclPermissionType"), aclPermissionType);
+}
+
 std::string DescribeAclsRequest::getUsername() const {
   return username_;
 }

alikafka/src/model/DescribeAclsResult.cc

@@ -55,6 +55,8 @@ void DescribeAclsResult::parse(const std::string &payload)
 			kafkaAclListObject.aclResourcePatternType = valueKafkaAclListKafkaAclVO["AclResourcePatternType"].asString();
 		if(!valueKafkaAclListKafkaAclVO["Username"].isNull())
 			kafkaAclListObject.username = valueKafkaAclListKafkaAclVO["Username"].asString();
+		if(!valueKafkaAclListKafkaAclVO["AclPermissionType"].isNull())
+			kafkaAclListObject.aclPermissionType = valueKafkaAclListKafkaAclVO["AclPermissionType"].asString();
 		kafkaAclList_.push_back(kafkaAclListObject);
 	}
 	if(!value["Code"].isNull())

alikafka/src/model/DescribeSaslUsersResult.cc

@@ -49,6 +49,8 @@ void DescribeSaslUsersResult::parse(const std::string &payload)
 			saslUserListObject.password = valueSaslUserListSaslUserVO["Password"].asString();
 		if(!valueSaslUserListSaslUserVO["Username"].isNull())
 			saslUserListObject.username = valueSaslUserListSaslUserVO["Username"].asString();
+		if(!valueSaslUserListSaslUserVO["Mechanism"].isNull())
+			saslUserListObject.mechanism = valueSaslUserListSaslUserVO["Mechanism"].asString();
 		saslUserList_.push_back(saslUserListObject);
 	}
 	if(!value["Code"].isNull())

alikafka/src/model/EnableAutoGroupCreationRequest.cc

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h>
+
+using AlibabaCloud::Alikafka::Model::EnableAutoGroupCreationRequest;
+
+EnableAutoGroupCreationRequest::EnableAutoGroupCreationRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "EnableAutoGroupCreation") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+EnableAutoGroupCreationRequest::~EnableAutoGroupCreationRequest() {}
+
+std::string EnableAutoGroupCreationRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void EnableAutoGroupCreationRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string EnableAutoGroupCreationRequest::getRegionId() const {
+  return regionId_;
+}
+
+void EnableAutoGroupCreationRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+
+bool EnableAutoGroupCreationRequest::getEnable() const {
+  return enable_;
+}
+
+void EnableAutoGroupCreationRequest::setEnable(bool enable) {
+  enable_ = enable;
+  setParameter(std::string("Enable"), enable ? "true" : "false");
+}
+

alikafka/src/model/EnableAutoGroupCreationResult.cc

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+EnableAutoGroupCreationResult::EnableAutoGroupCreationResult() :
+	ServiceResult()
+{}
+
+EnableAutoGroupCreationResult::EnableAutoGroupCreationResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+EnableAutoGroupCreationResult::~EnableAutoGroupCreationResult()
+{}
+
+void EnableAutoGroupCreationResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+
+}
+
+std::string EnableAutoGroupCreationResult::getMessage()const
+{
+	return message_;
+}
+
+int EnableAutoGroupCreationResult::getCode()const
+{
+	return code_;
+}
+
+bool EnableAutoGroupCreationResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/EnableAutoTopicCreationRequest.cc

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h>
+
+using AlibabaCloud::Alikafka::Model::EnableAutoTopicCreationRequest;
+
+EnableAutoTopicCreationRequest::EnableAutoTopicCreationRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "EnableAutoTopicCreation") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+EnableAutoTopicCreationRequest::~EnableAutoTopicCreationRequest() {}
+
+std::string EnableAutoTopicCreationRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void EnableAutoTopicCreationRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string EnableAutoTopicCreationRequest::getOperate() const {
+  return operate_;
+}
+
+void EnableAutoTopicCreationRequest::setOperate(const std::string &operate) {
+  operate_ = operate;
+  setParameter(std::string("Operate"), operate);
+}
+
+std::string EnableAutoTopicCreationRequest::getRegionId() const {
+  return regionId_;
+}
+
+void EnableAutoTopicCreationRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+
+long EnableAutoTopicCreationRequest::getPartitionNum() const {
+  return partitionNum_;
+}
+
+void EnableAutoTopicCreationRequest::setPartitionNum(long partitionNum) {
+  partitionNum_ = partitionNum;
+  setParameter(std::string("PartitionNum"), std::to_string(partitionNum));
+}
+

alikafka/src/model/EnableAutoTopicCreationResult.cc

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+EnableAutoTopicCreationResult::EnableAutoTopicCreationResult() :
+	ServiceResult()
+{}
+
+EnableAutoTopicCreationResult::EnableAutoTopicCreationResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+EnableAutoTopicCreationResult::~EnableAutoTopicCreationResult()
+{}
+
+void EnableAutoTopicCreationResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+
+}
+
+std::string EnableAutoTopicCreationResult::getMessage()const
+{
+	return message_;
+}
+
+int EnableAutoTopicCreationResult::getCode()const
+{
+	return code_;
+}
+
+bool EnableAutoTopicCreationResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/GetConsumerListResult.cc

@@ -71,6 +71,12 @@ void GetConsumerListResult::parse(const std::string &payload)
 		message_ = value["Message"].asString();
 	if(!value["Success"].isNull())
 		success_ = value["Success"].asString() == "true";
+	if(!value["Total"].isNull())
+		total_ = std::stol(value["Total"].asString());
+	if(!value["PageSize"].isNull())
+		pageSize_ = std::stoi(value["PageSize"].asString());
+	if(!value["CurrentPage"].isNull())
+		currentPage_ = std::stoi(value["CurrentPage"].asString());
 
 }
 
@@ -79,6 +85,21 @@ std::string GetConsumerListResult::getMessage()const
 	return message_;
 }
 
+int GetConsumerListResult::getPageSize()const
+{
+	return pageSize_;
+}
+
+int GetConsumerListResult::getCurrentPage()const
+{
+	return currentPage_;
+}
+
+long GetConsumerListResult::getTotal()const
+{
+	return total_;
+}
+
 std::vector<GetConsumerListResult::ConsumerVO> GetConsumerListResult::getConsumerList()const
 {
 	return consumerList_;

alikafka/src/model/GetConsumerProgressResult.cc

@@ -70,6 +70,24 @@ void GetConsumerProgressResult::parse(const std::string &payload)
 		}
 		consumerProgress_.topicList.push_back(topicListItemObject);
 	}
+	auto allRebalanceInfoListNode = consumerProgressNode["RebalanceInfoList"]["RebalanceInfoListItem"];
+	for (auto consumerProgressNodeRebalanceInfoListRebalanceInfoListItem : allRebalanceInfoListNode)
+	{
+		ConsumerProgress::RebalanceInfoListItem rebalanceInfoListItemObject;
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Generation"].isNull())
+			rebalanceInfoListItemObject.generation = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Generation"].asString());
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["LastRebalanceTimestamp"].isNull())
+			rebalanceInfoListItemObject.lastRebalanceTimestamp = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["LastRebalanceTimestamp"].asString());
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Reason"].isNull())
+			rebalanceInfoListItemObject.reason = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Reason"].asString();
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["GroupId"].isNull())
+			rebalanceInfoListItemObject.groupId = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["GroupId"].asString();
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceTimeConsuming"].isNull())
+			rebalanceInfoListItemObject.rebalanceTimeConsuming = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceTimeConsuming"].asString());
+		if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceSuccess"].isNull())
+			rebalanceInfoListItemObject.rebalanceSuccess = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceSuccess"].asString() == "true";
+		consumerProgress_.rebalanceInfoList.push_back(rebalanceInfoListItemObject);
+	}
 	if(!value["Code"].isNull())
 		code_ = std::stoi(value["Code"].asString());
 	if(!value["Message"].isNull())

alikafka/src/model/GetInstanceListResult.cc

@@ -107,6 +107,12 @@ void GetInstanceListResult::parse(const std::string &payload)
 			instanceListObject.standardZoneId = valueInstanceListInstanceVO["StandardZoneId"].asString();
 		if(!valueInstanceListInstanceVO["IoMaxSpec"].isNull())
 			instanceListObject.ioMaxSpec = valueInstanceListInstanceVO["IoMaxSpec"].asString();
+		if(!valueInstanceListInstanceVO["ReservedPublishCapacity"].isNull())
+			instanceListObject.reservedPublishCapacity = std::stoi(valueInstanceListInstanceVO["ReservedPublishCapacity"].asString());
+		if(!valueInstanceListInstanceVO["ReservedSubscribeCapacity"].isNull())
+			instanceListObject.reservedSubscribeCapacity = std::stoi(valueInstanceListInstanceVO["ReservedSubscribeCapacity"].asString());
+		if(!valueInstanceListInstanceVO["ViewInstanceStatusCode"].isNull())
+			instanceListObject.viewInstanceStatusCode = std::stoi(valueInstanceListInstanceVO["ViewInstanceStatusCode"].asString());
 		auto allTagsNode = valueInstanceListInstanceVO["Tags"]["TagVO"];
 		for (auto valueInstanceListInstanceVOTagsTagVO : allTagsNode)
 		{
@@ -120,6 +126,43 @@ void GetInstanceListResult::parse(const std::string &payload)
 		auto upgradeServiceDetailInfoNode = value["UpgradeServiceDetailInfo"];
 		if(!upgradeServiceDetailInfoNode["Current2OpenSourceVersion"].isNull())
 			instanceListObject.upgradeServiceDetailInfo.current2OpenSourceVersion = upgradeServiceDetailInfoNode["Current2OpenSourceVersion"].asString();
+		auto confluentConfigNode = value["ConfluentConfig"];
+		if(!confluentConfigNode["KafkaCU"].isNull())
+			instanceListObject.confluentConfig.kafkaCU = std::stoi(confluentConfigNode["KafkaCU"].asString());
+		if(!confluentConfigNode["KafkaStorage"].isNull())
+			instanceListObject.confluentConfig.kafkaStorage = std::stoi(confluentConfigNode["KafkaStorage"].asString());
+		if(!confluentConfigNode["KafkaReplica"].isNull())
+			instanceListObject.confluentConfig.kafkaReplica = std::stoi(confluentConfigNode["KafkaReplica"].asString());
+		if(!confluentConfigNode["ZooKeeperCU"].isNull())
+			instanceListObject.confluentConfig.zooKeeperCU = std::stoi(confluentConfigNode["ZooKeeperCU"].asString());
+		if(!confluentConfigNode["ZooKeeperStorage"].isNull())
+			instanceListObject.confluentConfig.zooKeeperStorage = std::stoi(confluentConfigNode["ZooKeeperStorage"].asString());
+		if(!confluentConfigNode["ZooKeeperReplica"].isNull())
+			instanceListObject.confluentConfig.zooKeeperReplica = std::stoi(confluentConfigNode["ZooKeeperReplica"].asString());
+		if(!confluentConfigNode["ControlCenterCU"].isNull())
+			instanceListObject.confluentConfig.controlCenterCU = std::stoi(confluentConfigNode["ControlCenterCU"].asString());
+		if(!confluentConfigNode["ControlCenterStorage"].isNull())
+			instanceListObject.confluentConfig.controlCenterStorage = std::stoi(confluentConfigNode["ControlCenterStorage"].asString());
+		if(!confluentConfigNode["ControlCenterReplica"].isNull())
+			instanceListObject.confluentConfig.controlCenterReplica = std::stoi(confluentConfigNode["ControlCenterReplica"].asString());
+		if(!confluentConfigNode["SchemaRegistryCU"].isNull())
+			instanceListObject.confluentConfig.schemaRegistryCU = std::stoi(confluentConfigNode["SchemaRegistryCU"].asString());
+		if(!confluentConfigNode["SchemaRegistryReplica"].isNull())
+			instanceListObject.confluentConfig.schemaRegistryReplica = std::stoi(confluentConfigNode["SchemaRegistryReplica"].asString());
+		if(!confluentConfigNode["ConnectCU"].isNull())
+			instanceListObject.confluentConfig.connectCU = std::stoi(confluentConfigNode["ConnectCU"].asString());
+		if(!confluentConfigNode["ConnectReplica"].isNull())
+			instanceListObject.confluentConfig.connectReplica = std::stoi(confluentConfigNode["ConnectReplica"].asString());
+		if(!confluentConfigNode["KsqlCU"].isNull())
+			instanceListObject.confluentConfig.ksqlCU = std::stoi(confluentConfigNode["KsqlCU"].asString());
+		if(!confluentConfigNode["KsqlStorage"].isNull())
+			instanceListObject.confluentConfig.ksqlStorage = std::stoi(confluentConfigNode["KsqlStorage"].asString());
+		if(!confluentConfigNode["KsqlReplica"].isNull())
+			instanceListObject.confluentConfig.ksqlReplica = std::stoi(confluentConfigNode["KsqlReplica"].asString());
+		if(!confluentConfigNode["KafkaRestProxyCU"].isNull())
+			instanceListObject.confluentConfig.kafkaRestProxyCU = std::stoi(confluentConfigNode["KafkaRestProxyCU"].asString());
+		if(!confluentConfigNode["KafkaRestProxyReplica"].isNull())
+			instanceListObject.confluentConfig.kafkaRestProxyReplica = std::stoi(confluentConfigNode["KafkaRestProxyReplica"].asString());
 		instanceList_.push_back(instanceListObject);
 	}
 	if(!value["Code"].isNull())

alikafka/src/model/GetTopicSubscribeStatusRequest.cc

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h>
+
+using AlibabaCloud::Alikafka::Model::GetTopicSubscribeStatusRequest;
+
+GetTopicSubscribeStatusRequest::GetTopicSubscribeStatusRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "GetTopicSubscribeStatus") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+GetTopicSubscribeStatusRequest::~GetTopicSubscribeStatusRequest() {}
+
+std::string GetTopicSubscribeStatusRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void GetTopicSubscribeStatusRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string GetTopicSubscribeStatusRequest::getRegionId() const {
+  return regionId_;
+}
+
+void GetTopicSubscribeStatusRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+
+std::string GetTopicSubscribeStatusRequest::getTopic() const {
+  return topic_;
+}
+
+void GetTopicSubscribeStatusRequest::setTopic(const std::string &topic) {
+  topic_ = topic;
+  setParameter(std::string("Topic"), topic);
+}
+

alikafka/src/model/GetTopicSubscribeStatusResult.cc

@@ -0,0 +1,76 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+GetTopicSubscribeStatusResult::GetTopicSubscribeStatusResult() :
+	ServiceResult()
+{}
+
+GetTopicSubscribeStatusResult::GetTopicSubscribeStatusResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+GetTopicSubscribeStatusResult::~GetTopicSubscribeStatusResult()
+{}
+
+void GetTopicSubscribeStatusResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	auto topicSubscribeStatusNode = value["TopicSubscribeStatus"];
+	if(!topicSubscribeStatusNode["Topic"].isNull())
+		topicSubscribeStatus_.topic = topicSubscribeStatusNode["Topic"].asString();
+		auto allConsumerGroups = topicSubscribeStatusNode["ConsumerGroups"]["ConsumerGroups"];
+		for (auto value : allConsumerGroups)
+			topicSubscribeStatus_.consumerGroups.push_back(value.asString());
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+
+}
+
+std::string GetTopicSubscribeStatusResult::getMessage()const
+{
+	return message_;
+}
+
+GetTopicSubscribeStatusResult::TopicSubscribeStatus GetTopicSubscribeStatusResult::getTopicSubscribeStatus()const
+{
+	return topicSubscribeStatus_;
+}
+
+int GetTopicSubscribeStatusResult::getCode()const
+{
+	return code_;
+}
+
+bool GetTopicSubscribeStatusResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/ModifyTopicRemarkRequest.cc

@@ -25,6 +25,15 @@ ModifyTopicRemarkRequest::ModifyTopicRemarkRequest()
 
 ModifyTopicRemarkRequest::~ModifyTopicRemarkRequest() {}
 
+std::string ModifyTopicRemarkRequest::getRemark() const {
+  return remark_;
+}
+
+void ModifyTopicRemarkRequest::setRemark(const std::string &remark) {
+  remark_ = remark;
+  setParameter(std::string("Remark"), remark);
+}
+
 std::string ModifyTopicRemarkRequest::getInstanceId() const {
   return instanceId_;
 }
@@ -52,12 +61,3 @@ void ModifyTopicRemarkRequest::setTopic(const std::string &topic) {
   setParameter(std::string("Topic"), topic);
 }
 
-std::string ModifyTopicRemarkRequest::getRemark() const {
-  return remark_;
-}
-
-void ModifyTopicRemarkRequest::setRemark(const std::string &remark) {
-  remark_ = remark;
-  setParameter(std::string("Remark"), remark);
-}
-

alikafka/src/model/QueryMessageRequest.cc

@@ -0,0 +1,90 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/QueryMessageRequest.h>
+
+using AlibabaCloud::Alikafka::Model::QueryMessageRequest;
+
+QueryMessageRequest::QueryMessageRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "QueryMessage") {
+  setMethod(HttpRequest::Method::Get);
+}
+
+QueryMessageRequest::~QueryMessageRequest() {}
+
+std::string QueryMessageRequest::getOffset() const {
+  return offset_;
+}
+
+void QueryMessageRequest::setOffset(const std::string &offset) {
+  offset_ = offset;
+  setParameter(std::string("Offset"), offset);
+}
+
+long QueryMessageRequest::getBeginTime() const {
+  return beginTime_;
+}
+
+void QueryMessageRequest::setBeginTime(long beginTime) {
+  beginTime_ = beginTime;
+  setParameter(std::string("BeginTime"), std::to_string(beginTime));
+}
+
+std::string QueryMessageRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void QueryMessageRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string QueryMessageRequest::getPartition() const {
+  return partition_;
+}
+
+void QueryMessageRequest::setPartition(const std::string &partition) {
+  partition_ = partition;
+  setParameter(std::string("Partition"), partition);
+}
+
+std::string QueryMessageRequest::getRegionId() const {
+  return regionId_;
+}
+
+void QueryMessageRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+
+std::string QueryMessageRequest::getTopic() const {
+  return topic_;
+}
+
+void QueryMessageRequest::setTopic(const std::string &topic) {
+  topic_ = topic;
+  setParameter(std::string("Topic"), topic);
+}
+
+std::string QueryMessageRequest::getQueryType() const {
+  return queryType_;
+}
+
+void QueryMessageRequest::setQueryType(const std::string &queryType) {
+  queryType_ = queryType;
+  setParameter(std::string("QueryType"), queryType);
+}
+

alikafka/src/model/QueryMessageResult.cc

@@ -0,0 +1,104 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/QueryMessageResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+QueryMessageResult::QueryMessageResult() :
+	ServiceResult()
+{}
+
+QueryMessageResult::QueryMessageResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+QueryMessageResult::~QueryMessageResult()
+{}
+
+void QueryMessageResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	auto allMessageListNode = value["MessageList"]["MessageVO"];
+	for (auto valueMessageListMessageVO : allMessageListNode)
+	{
+		MessageVO messageListObject;
+		if(!valueMessageListMessageVO["Topic"].isNull())
+			messageListObject.topic = valueMessageListMessageVO["Topic"].asString();
+		if(!valueMessageListMessageVO["Partition"].isNull())
+			messageListObject.partition = std::stol(valueMessageListMessageVO["Partition"].asString());
+		if(!valueMessageListMessageVO["Offset"].isNull())
+			messageListObject.offset = std::stol(valueMessageListMessageVO["Offset"].asString());
+		if(!valueMessageListMessageVO["Timestamp"].isNull())
+			messageListObject.timestamp = std::stol(valueMessageListMessageVO["Timestamp"].asString());
+		if(!valueMessageListMessageVO["TimestampType"].isNull())
+			messageListObject.timestampType = valueMessageListMessageVO["TimestampType"].asString();
+		if(!valueMessageListMessageVO["Checksum"].isNull())
+			messageListObject.checksum = std::stol(valueMessageListMessageVO["Checksum"].asString());
+		if(!valueMessageListMessageVO["SerializedKeySize"].isNull())
+			messageListObject.serializedKeySize = std::stoi(valueMessageListMessageVO["SerializedKeySize"].asString());
+		if(!valueMessageListMessageVO["SerializedValueSize"].isNull())
+			messageListObject.serializedValueSize = std::stoi(valueMessageListMessageVO["SerializedValueSize"].asString());
+		if(!valueMessageListMessageVO["Key"].isNull())
+			messageListObject.key = valueMessageListMessageVO["Key"].asString();
+		if(!valueMessageListMessageVO["Value"].isNull())
+			messageListObject.value = valueMessageListMessageVO["Value"].asString();
+		if(!valueMessageListMessageVO["KeyTruncated"].isNull())
+			messageListObject.keyTruncated = valueMessageListMessageVO["KeyTruncated"].asString() == "true";
+		if(!valueMessageListMessageVO["ValueTruncated"].isNull())
+			messageListObject.valueTruncated = valueMessageListMessageVO["ValueTruncated"].asString() == "true";
+		if(!valueMessageListMessageVO["TruncatedKeySize"].isNull())
+			messageListObject.truncatedKeySize = std::stoi(valueMessageListMessageVO["TruncatedKeySize"].asString());
+		if(!valueMessageListMessageVO["TruncatedValueSize"].isNull())
+			messageListObject.truncatedValueSize = std::stoi(valueMessageListMessageVO["TruncatedValueSize"].asString());
+		messageList_.push_back(messageListObject);
+	}
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+
+}
+
+std::string QueryMessageResult::getMessage()const
+{
+	return message_;
+}
+
+int QueryMessageResult::getCode()const
+{
+	return code_;
+}
+
+std::vector<QueryMessageResult::MessageVO> QueryMessageResult::getMessageList()const
+{
+	return messageList_;
+}
+
+bool QueryMessageResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/ReopenInstanceRequest.cc

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/ReopenInstanceRequest.h>
+
+using AlibabaCloud::Alikafka::Model::ReopenInstanceRequest;
+
+ReopenInstanceRequest::ReopenInstanceRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "ReopenInstance") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+ReopenInstanceRequest::~ReopenInstanceRequest() {}
+
+std::string ReopenInstanceRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void ReopenInstanceRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string ReopenInstanceRequest::getRegionId() const {
+  return regionId_;
+}
+
+void ReopenInstanceRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+

alikafka/src/model/ReopenInstanceResult.cc

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/ReopenInstanceResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+ReopenInstanceResult::ReopenInstanceResult() :
+	ServiceResult()
+{}
+
+ReopenInstanceResult::ReopenInstanceResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+ReopenInstanceResult::~ReopenInstanceResult()
+{}
+
+void ReopenInstanceResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+
+}
+
+std::string ReopenInstanceResult::getMessage()const
+{
+	return message_;
+}
+
+int ReopenInstanceResult::getCode()const
+{
+	return code_;
+}
+
+bool ReopenInstanceResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/StartInstanceRequest.cc

@@ -25,6 +25,14 @@ StartInstanceRequest::StartInstanceRequest()
 
 StartInstanceRequest::~StartInstanceRequest() {}
 
+std::vector<std::string> StartInstanceRequest::getVSwitchIds() const {
+  return vSwitchIds_;
+}
+
+void StartInstanceRequest::setVSwitchIds(const std::vector<std::string> &vSwitchIds) {
+  vSwitchIds_ = vSwitchIds;
+}
+
 std::string StartInstanceRequest::getSelectedZones() const {
   return selectedZones_;
 }

alikafka/src/model/StopInstanceRequest.cc

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/StopInstanceRequest.h>
+
+using AlibabaCloud::Alikafka::Model::StopInstanceRequest;
+
+StopInstanceRequest::StopInstanceRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "StopInstance") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+StopInstanceRequest::~StopInstanceRequest() {}
+
+std::string StopInstanceRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void StopInstanceRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string StopInstanceRequest::getRegionId() const {
+  return regionId_;
+}
+
+void StopInstanceRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+

alikafka/src/model/StopInstanceResult.cc

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/StopInstanceResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+StopInstanceResult::StopInstanceResult() :
+	ServiceResult()
+{}
+
+StopInstanceResult::StopInstanceResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+StopInstanceResult::~StopInstanceResult()
+{}
+
+void StopInstanceResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	if(!value["Code"].isNull())
+		code_ = std::stoi(value["Code"].asString());
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+
+}
+
+std::string StopInstanceResult::getMessage()const
+{
+	return message_;
+}
+
+int StopInstanceResult::getCode()const
+{
+	return code_;
+}
+
+bool StopInstanceResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/UpdateTopicConfigRequest.cc

@@ -0,0 +1,72 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/UpdateTopicConfigRequest.h>
+
+using AlibabaCloud::Alikafka::Model::UpdateTopicConfigRequest;
+
+UpdateTopicConfigRequest::UpdateTopicConfigRequest()
+    : RpcServiceRequest("alikafka", "2019-09-16", "UpdateTopicConfig") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+UpdateTopicConfigRequest::~UpdateTopicConfigRequest() {}
+
+std::string UpdateTopicConfigRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void UpdateTopicConfigRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string UpdateTopicConfigRequest::getRegionId() const {
+  return regionId_;
+}
+
+void UpdateTopicConfigRequest::setRegionId(const std::string &regionId) {
+  regionId_ = regionId;
+  setParameter(std::string("RegionId"), regionId);
+}
+
+std::string UpdateTopicConfigRequest::getTopic() const {
+  return topic_;
+}
+
+void UpdateTopicConfigRequest::setTopic(const std::string &topic) {
+  topic_ = topic;
+  setParameter(std::string("Topic"), topic);
+}
+
+std::string UpdateTopicConfigRequest::getConfig() const {
+  return config_;
+}
+
+void UpdateTopicConfigRequest::setConfig(const std::string &config) {
+  config_ = config;
+  setParameter(std::string("Config"), config);
+}
+
+std::string UpdateTopicConfigRequest::getValue() const {
+  return value_;
+}
+
+void UpdateTopicConfigRequest::setValue(const std::string &value) {
+  value_ = value;
+  setParameter(std::string("Value"), value);
+}
+

alikafka/src/model/UpdateTopicConfigResult.cc

@@ -0,0 +1,72 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/alikafka/model/UpdateTopicConfigResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Alikafka;
+using namespace AlibabaCloud::Alikafka::Model;
+
+UpdateTopicConfigResult::UpdateTopicConfigResult() :
+	ServiceResult()
+{}
+
+UpdateTopicConfigResult::UpdateTopicConfigResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+UpdateTopicConfigResult::~UpdateTopicConfigResult()
+{}
+
+void UpdateTopicConfigResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+	if(!value["Code"].isNull())
+		code_ = std::stol(value["Code"].asString());
+	if(!value["Message"].isNull())
+		message_ = value["Message"].asString();
+	if(!value["Data"].isNull())
+		data_ = value["Data"].asString();
+
+}
+
+std::string UpdateTopicConfigResult::getMessage()const
+{
+	return message_;
+}
+
+std::string UpdateTopicConfigResult::getData()const
+{
+	return data_;
+}
+
+long UpdateTopicConfigResult::getCode()const
+{
+	return code_;
+}
+
+bool UpdateTopicConfigResult::getSuccess()const
+{
+	return success_;
+}
+

alikafka/src/model/UpgradePostPayOrderRequest.cc

@@ -25,6 +25,16 @@ UpgradePostPayOrderRequest::UpgradePostPayOrderRequest()
 
 UpgradePostPayOrderRequest::~UpgradePostPayOrderRequest() {}
 
+UpgradePostPayOrderRequest::ServerlessConfig UpgradePostPayOrderRequest::getServerlessConfig() const {
+  return serverlessConfig_;
+}
+
+void UpgradePostPayOrderRequest::setServerlessConfig(const UpgradePostPayOrderRequest::ServerlessConfig &serverlessConfig) {
+  serverlessConfig_ = serverlessConfig;
+  setParameter(std::string("ServerlessConfig") + ".ReservedPublishCapacity", std::to_string(serverlessConfig.reservedPublishCapacity));
+  setParameter(std::string("ServerlessConfig") + ".ReservedSubscribeCapacity", std::to_string(serverlessConfig.reservedSubscribeCapacity));
+}
+
 int UpgradePostPayOrderRequest::getDiskSize() const {
   return diskSize_;
 }

alikafka/src/model/UpgradePrePayOrderRequest.cc

@@ -25,15 +25,6 @@ UpgradePrePayOrderRequest::UpgradePrePayOrderRequest()
 
 UpgradePrePayOrderRequest::~UpgradePrePayOrderRequest() {}
 
-int UpgradePrePayOrderRequest::getDiskSize() const {
-  return diskSize_;
-}
-
-void UpgradePrePayOrderRequest::setDiskSize(int diskSize) {
-  diskSize_ = diskSize;
-  setParameter(std::string("DiskSize"), std::to_string(diskSize));
-}
-
 int UpgradePrePayOrderRequest::getIoMax() const {
   return ioMax_;
 }
@@ -52,24 +43,6 @@ void UpgradePrePayOrderRequest::setEipModel(bool eipModel) {
   setParameter(std::string("EipModel"), eipModel ? "true" : "false");
 }
 
-std::string UpgradePrePayOrderRequest::getIoMaxSpec() const {
-  return ioMaxSpec_;
-}
-
-void UpgradePrePayOrderRequest::setIoMaxSpec(const std::string &ioMaxSpec) {
-  ioMaxSpec_ = ioMaxSpec;
-  setParameter(std::string("IoMaxSpec"), ioMaxSpec);
-}
-
-int UpgradePrePayOrderRequest::getTopicQuota() const {
-  return topicQuota_;
-}
-
-void UpgradePrePayOrderRequest::setTopicQuota(int topicQuota) {
-  topicQuota_ = topicQuota;
-  setParameter(std::string("TopicQuota"), std::to_string(topicQuota));
-}
-
 int UpgradePrePayOrderRequest::getEipMax() const {
   return eipMax_;
 }
@@ -88,15 +61,6 @@ void UpgradePrePayOrderRequest::setSpecType(const std::string &specType) {
   setParameter(std::string("SpecType"), specType);
 }
 
-std::string UpgradePrePayOrderRequest::getInstanceId() const {
-  return instanceId_;
-}
-
-void UpgradePrePayOrderRequest::setInstanceId(const std::string &instanceId) {
-  instanceId_ = instanceId;
-  setParameter(std::string("InstanceId"), instanceId);
-}
-
 std::string UpgradePrePayOrderRequest::getRegionId() const {
   return regionId_;
 }
@@ -106,6 +70,32 @@ void UpgradePrePayOrderRequest::setRegionId(const std::string &regionId) {
   setParameter(std::string("RegionId"), regionId);
 }
 
+UpgradePrePayOrderRequest::ConfluentConfig UpgradePrePayOrderRequest::getConfluentConfig() const {
+  return confluentConfig_;
+}
+
+void UpgradePrePayOrderRequest::setConfluentConfig(const UpgradePrePayOrderRequest::ConfluentConfig &confluentConfig) {
+  confluentConfig_ = confluentConfig;
+  setParameter(std::string("ConfluentConfig") + ".KsqlStorage", std::to_string(confluentConfig.ksqlStorage));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterStorage", std::to_string(confluentConfig.controlCenterStorage));
+  setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyReplica", std::to_string(confluentConfig.kafkaRestProxyReplica));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperReplica", std::to_string(confluentConfig.zooKeeperReplica));
+  setParameter(std::string("ConfluentConfig") + ".ConnectCU", std::to_string(confluentConfig.connectCU));
+  setParameter(std::string("ConfluentConfig") + ".KafkaReplica", std::to_string(confluentConfig.kafkaReplica));
+  setParameter(std::string("ConfluentConfig") + ".SchemaRegistryReplica", std::to_string(confluentConfig.schemaRegistryReplica));
+  setParameter(std::string("ConfluentConfig") + ".KafkaCU", std::to_string(confluentConfig.kafkaCU));
+  setParameter(std::string("ConfluentConfig") + ".ConnectReplica", std::to_string(confluentConfig.connectReplica));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterCU", std::to_string(confluentConfig.controlCenterCU));
+  setParameter(std::string("ConfluentConfig") + ".KsqlReplica", std::to_string(confluentConfig.ksqlReplica));
+  setParameter(std::string("ConfluentConfig") + ".ControlCenterReplica", std::to_string(confluentConfig.controlCenterReplica));
+  setParameter(std::string("ConfluentConfig") + ".KafkaStorage", std::to_string(confluentConfig.kafkaStorage));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperStorage", std::to_string(confluentConfig.zooKeeperStorage));
+  setParameter(std::string("ConfluentConfig") + ".KsqlCU", std::to_string(confluentConfig.ksqlCU));
+  setParameter(std::string("ConfluentConfig") + ".SchemaRegistryCU", std::to_string(confluentConfig.schemaRegistryCU));
+  setParameter(std::string("ConfluentConfig") + ".ZooKeeperCU", std::to_string(confluentConfig.zooKeeperCU));
+  setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyCU", std::to_string(confluentConfig.kafkaRestProxyCU));
+}
+
 int UpgradePrePayOrderRequest::getPartitionNum() const {
   return partitionNum_;
 }
@@ -115,3 +105,48 @@ void UpgradePrePayOrderRequest::setPartitionNum(int partitionNum) {
   setParameter(std::string("PartitionNum"), std::to_string(partitionNum));
 }
 
+int UpgradePrePayOrderRequest::getPaidType() const {
+  return paidType_;
+}
+
+void UpgradePrePayOrderRequest::setPaidType(int paidType) {
+  paidType_ = paidType;
+  setParameter(std::string("PaidType"), std::to_string(paidType));
+}
+
+int UpgradePrePayOrderRequest::getDiskSize() const {
+  return diskSize_;
+}
+
+void UpgradePrePayOrderRequest::setDiskSize(int diskSize) {
+  diskSize_ = diskSize;
+  setParameter(std::string("DiskSize"), std::to_string(diskSize));
+}
+
+std::string UpgradePrePayOrderRequest::getIoMaxSpec() const {
+  return ioMaxSpec_;
+}
+
+void UpgradePrePayOrderRequest::setIoMaxSpec(const std::string &ioMaxSpec) {
+  ioMaxSpec_ = ioMaxSpec;
+  setParameter(std::string("IoMaxSpec"), ioMaxSpec);
+}
+
+int UpgradePrePayOrderRequest::getTopicQuota() const {
+  return topicQuota_;
+}
+
+void UpgradePrePayOrderRequest::setTopicQuota(int topicQuota) {
+  topicQuota_ = topicQuota;
+  setParameter(std::string("TopicQuota"), std::to_string(topicQuota));
+}
+
+std::string UpgradePrePayOrderRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void UpgradePrePayOrderRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setParameter(std::string("InstanceId"), instanceId);
+}
+