~i0JdZddlmZddlZddlZddlZGddeZdS)z kafka No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen) # noqa: E501 OpenAPI spec version: common-version Generated by: https://github.com/swagger-api/swagger-codegen.git )absolute_importNcfeZdZdZdfdZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$d$Z%d%Z&d&Z'd'Z(d(Z)d)Z*d*Z+d+Z,d,Z-d-Z.d.Z/d/Z0d0Z1d1Z2d2Z3d3Z4d4Z5d5Z6d6Z7d7Z8d8Z9d9Z:d:Z;d;Zd>Z?d?Z@d@ZAdAZBdBZCdCZDdDZEdEZFdFZGdGZHdHZIdIZJdJZKdKZLdLZMdMZNdNZOdOZPdPZQdQZRdRZSdSZTdTZUdUZVdVZWdWZXdXZYdYZZdZZ[d[Z\d\Z]d]Z^d^Z_d_Z`d`ZadaZbdbZcdcZdddZedeZfdS)gKAFKAApizNOTE: This class is auto generated by the swagger code generator program. Do not edit the class manually. Ref: https://github.com/swagger-api/swagger-codegen Nc>|tj}||_dSN)volcenginesdkcore ApiClient api_client)selfr s i/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkkafka/api/kafka_api.py__init__zKAFKAApi.__init__s!  *466J$c rd|d<|dr|j|fi|S|j|fi|}|S)aadd_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. T_return_http_data_only async_req)get#add_tags_to_resource_with_http_infor bodykwargsdatas r add_tags_to_resourcezKAFKAApi.add_tags_to_resource$],0'( ::k " " ;4;DKKFKK K=T=dMMfMMTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aadd_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. rrr_preload_content_request_timeoutrzFGot an unexpected keyword argument '%s' to method add_tags_to_resourceNzIMissing the required parameter `body` when calling `add_tags_to_resource`application/jsonAccept Content-TypevolcengineSignz:/AddTagsToResource/2022-05-01/kafka/post/application_json/POSTAddTagsToResourceResponseT r post_paramsfiles response_type auth_settingsrrrrcollection_formats appendlocalssix iteritems TypeErrorr client_side_validation ValueErrorselect_header_acceptselect_header_content_typecall_apirr rr all_paramsparamskeyvalr( path_params query_params header_params form_paramslocal_var_files body_paramsr's r rz,KAFKAApi.add_tags_to_resource_with_http_info9sX +&&&2333,---,--- fX&677  HC*$$68;<F3KK 8  ? 1 jvV7K7K7=f~7Mhii i     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' H&   #!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r#associate_allow_list_with_http_infors r associate_allow_listzKAFKAApi.associate_allow_listrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method associate_allow_listNzIMissing the required parameter `body` when calling `associate_allow_list`rrrr z;/AssociateAllowList/2022-05-01/kafka/post/application_json/r!AssociateAllowListResponseTr#r)r4s r r@z,KAFKAApi.associate_allow_list_with_http_infoX +&&&2333,---,--- fX&677  HC*$$68;<F3KK 8  ? 1 jvV7K7K7=f~7Mhii i     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' I6   #!6'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_acl(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAclRequest body: (required) :return: CreateAclResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_acl_with_http_infors r create_aclzKAFKAApi.create_acl],0'( ::k " " 141$AA&AA A3T3DCCFCCTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_acl_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAclRequest body: (required) :return: CreateAclResponse If the method is called asynchronously, returns the request thread. rrrrrrz>> thread = api.create_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r create_allow_list_with_http_infors r create_allow_listzKAFKAApi.create_allow_listG],0'( ::k " " 848HHHH H:T:4JJ6JJTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a create_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method create_allow_listNzFMissing the required parameter `body` when calling `create_allow_list`rrrr z8/CreateAllowList/2022-05-01/kafka/post/application_json/r!CreateAllowListResponseTr#r)r4s r rMz)KAFKAApi.create_allow_list_with_http_info\X +&&&2333,---,--- fX&677  HC*$$3589F3KK 8  ? 1 gvV7K7K7=f~7Meff f     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' F   #!3'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_group_with_http_infors r create_groupzKAFKAApi.create_group],0'( ::k " " 343DCCFCC C5T5dEEfEETKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method create_groupNzAMissing the required parameter `body` when calling `create_group`rrrr z4/CreateGroup/2022-05-01/kafka/post/application_json/r!CreateGroupResponseTr#r)r4s r rTz$KAFKAApi.create_group_with_http_infoX +&&&2333,---,--- fX&677  HC*$$.034F3KK 8  ? 1 bvV7K7K7=f~7M`aa a     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' BF   #!/'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_instance_with_http_infors r create_instancezKAFKAApi.create_instance ],0'( ::k " " 646tFFvFF F8T8HHHHTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method create_instanceNzDMissing the required parameter `body` when calling `create_instance`rrrr z7/CreateInstance/2022-05-01/kafka/post/application_json/r!CreateInstanceResponseTr#r)r4s r r[z'KAFKAApi.create_instance_with_http_infoX +&&&2333,---,--- fX&677  HC*$$1367F3KK 8  ? 1 evV7K7K7=f~7Mcdd d     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Ev   #!2'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_migrate_sub_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateMigrateSubTasksRequest body: (required) :return: CreateMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. Trr)r'create_migrate_sub_tasks_with_http_infors r create_migrate_sub_tasksz!KAFKAApi.create_migrate_sub_tasksj],0'( ::k " " ?4?OOOO OATA$QQ&QQTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a$create_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_migrate_sub_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateMigrateSubTasksRequest body: (required) :return: CreateMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method create_migrate_sub_tasksNzMMissing the required parameter `body` when calling `create_migrate_sub_tasks`rrrr z>/CreateMigrateSubTasks/2022-05-01/kafka/post/application_json/r!CreateMigrateSubTasksResponseTr#r)r4s r rbz0KAFKAApi.create_migrate_sub_tasks_with_http_infoX +&&&2333,---,--- fX&677  HC*$$:>> thread = api.create_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. Trr)r$create_public_address_with_http_infors r create_public_addresszKAFKAApi.create_public_address],0'( ::k " " <4T>tNNvNNTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method create_public_addressNzJMissing the required parameter `body` when calling `create_public_address`rrrr z>> thread = api.create_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_topic_with_http_infors r create_topiczKAFKAApi.create_topic,rVrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method create_topicNzAMissing the required parameter `body` when calling `create_topic`rrrr z4/CreateTopic/2022-05-01/kafka/post/application_json/r!CreateTopicResponseTr#r)r4s r rpz$KAFKAApi.create_topic_with_http_infoArYrc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_user(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateUserRequest body: (required) :return: CreateUserResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_user_with_http_infors r create_userzKAFKAApi.create_user],0'( ::k " " 2424BB6BB B4T4TDDVDDTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_user_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateUserRequest body: (required) :return: CreateUserResponse If the method is called asynchronously, returns the request thread. rrrrrrz=Got an unexpected keyword argument '%s' to method create_userNz@Missing the required parameter `body` when calling `create_user`rrrr z3/CreateUser/2022-05-01/kafka/post/application_json/r!CreateUserResponseTr#r)r4s r ruz#KAFKAApi.create_user_with_http_infoX +&&&2333,---,--- fX&677  HC*$$-/23F3KK 8  ? 1 avV7K7K7=f~7M_`` `     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' A6   #!.'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_acl(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAclRequest body: (required) :return: DeleteAclResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_acl_with_http_infors r delete_aclzKAFKAApi.delete_aclrHrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_acl_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAclRequest body: (required) :return: DeleteAclResponse If the method is called asynchronously, returns the request thread. rrrrrrz>> thread = api.delete_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r delete_allow_list_with_http_infors r delete_allow_listzKAFKAApi.delete_allow_listOrOrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a delete_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method delete_allow_listNzFMissing the required parameter `body` when calling `delete_allow_list`rrrr z8/DeleteAllowList/2022-05-01/kafka/post/application_json/r!DeleteAllowListResponseTr#r)r4s r rz)KAFKAApi.delete_allow_list_with_http_infodrRrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_group_with_http_infors r delete_groupzKAFKAApi.delete_grouprVrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method delete_groupNzAMissing the required parameter `body` when calling `delete_group`rrrr z4/DeleteGroup/2022-05-01/kafka/post/application_json/r!DeleteGroupResponseTr#r)r4s r rz$KAFKAApi.delete_group_with_http_inforYrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_instance_with_http_infors r delete_instancezKAFKAApi.delete_instancer]rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method delete_instanceNzDMissing the required parameter `body` when calling `delete_instance`rrrr z7/DeleteInstance/2022-05-01/kafka/post/application_json/r!DeleteInstanceResponseTr#r)r4s r rz'KAFKAApi.delete_instance_with_http_info&r`rc rd|d<|dr|j|fi|S|j|fi|}|S)a delete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. Trr)r$delete_public_address_with_http_infors r delete_public_addresszKAFKAApi.delete_public_addressrrkrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method delete_public_addressNzJMissing the required parameter `body` when calling `delete_public_address`rrrr z>> thread = api.delete_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_topic_with_http_infors r delete_topiczKAFKAApi.delete_topicrVrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method delete_topicNzAMissing the required parameter `body` when calling `delete_topic`rrrr z4/DeleteTopic/2022-05-01/kafka/post/application_json/r!DeleteTopicResponseTr#r)r4s r rz$KAFKAApi.delete_topic_with_http_inforYrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_user(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteUserRequest body: (required) :return: DeleteUserResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_user_with_http_infors r delete_userzKAFKAApi.delete_user4rwrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_user_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteUserRequest body: (required) :return: DeleteUserResponse If the method is called asynchronously, returns the request thread. rrrrrrz=Got an unexpected keyword argument '%s' to method delete_userNz@Missing the required parameter `body` when calling `delete_user`rrrr z3/DeleteUser/2022-05-01/kafka/post/application_json/r!DeleteUserResponseTr#r)r4s r rz#KAFKAApi.delete_user_with_http_infoIrzrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_acls # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_acls(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAclsRequest body: (required) :return: DescribeAclsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_acls_with_http_infors r describe_aclszKAFKAApi.describe_aclss],0'( ::k " " 444TDDVDD D6T6tFFvFFTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_acls # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_acls_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAclsRequest body: (required) :return: DescribeAclsResponse If the method is called asynchronously, returns the request thread. rrrrrrz?Got an unexpected keyword argument '%s' to method describe_aclsNzBMissing the required parameter `body` when calling `describe_acls`rrrr z5/DescribeAcls/2022-05-01/kafka/post/application_json/r!DescribeAclsResponseTr#r)r4s r rz%KAFKAApi.describe_acls_with_http_infosX +&&&2333,---,--- fX&677  HC*$$/145F3KK 8  ? 1 cvV7K7K7=f~7Mabb b     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' CV   #!0'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. Trr)r)describe_allow_list_detail_with_http_infors r describe_allow_list_detailz#KAFKAApi.describe_allow_list_detail],0'( ::k " " A4A$QQ&QQ QCTCDSSFSSTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,describe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method describe_allow_list_detailNzOMissing the required parameter `body` when calling `describe_allow_list_detail`rrrr z@/DescribeAllowListDetail/2022-05-01/kafka/post/application_json/r!DescribeAllowListDetailResponseTr#r)r4s r rz2KAFKAApi.describe_allow_list_detail_with_http_info X +&&&2333,---,--- fX&677  HC*$$<>ABF3KK 8  ? 1 pvV7K7K7=f~7Mnoo o     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' NPV   #!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. Trr)r#describe_allow_lists_with_http_infors r describe_allow_listszKAFKAApi.describe_allow_listsWrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method describe_allow_listsNzIMissing the required parameter `body` when calling `describe_allow_lists`rrrr z;/DescribeAllowLists/2022-05-01/kafka/post/application_json/r!DescribeAllowListsResponseTr#r)r4s r rz,KAFKAApi.describe_allow_lists_with_http_infolrDrc rd|d<|dr|j|fi|S|j|fi|}|S)a#describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. Trr)r*describe_availability_zones_with_http_infors r describe_availability_zonesz$KAFKAApi.describe_availability_zones],0'( ::k " " B4B4RR6RR RDTDTTTVTTTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a2describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method describe_availability_zonesNzPMissing the required parameter `body` when calling `describe_availability_zones`rrrr zB/DescribeAvailabilityZones/2022-05-01/kafka/post/application_json/r!!DescribeAvailabilityZonesResponseTr#r)r4s r rz3KAFKAApi.describe_availability_zones_with_http_infosX +&&&2333,---,--- fX&677  HC*$$=?BCF3KK 8  ? 1 qvV7K7K7=f~7Mopp p     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' PRX   #!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a'describe_consumed_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_partitions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedPartitionsRequest body: (required) :return: DescribeConsumedPartitionsResponse If the method is called asynchronously, returns the request thread. Trr)r+describe_consumed_partitions_with_http_infors r describe_consumed_partitionsz%KAFKAApi.describe_consumed_partitions],0'( ::k " " C4CDSSFSS SETEdUUfUUTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a6describe_consumed_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_partitions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedPartitionsRequest body: (required) :return: DescribeConsumedPartitionsResponse If the method is called asynchronously, returns the request thread. rrrrrrzNGot an unexpected keyword argument '%s' to method describe_consumed_partitionsNzQMissing the required parameter `body` when calling `describe_consumed_partitions`rrrr zC/DescribeConsumedPartitions/2022-05-01/kafka/post/application_json/r!"DescribeConsumedPartitionsResponseTr#r)r4s r rz4KAFKAApi.describe_consumed_partitions_with_http_info.sX +&&&2333,---,--- fX&677  HC*$$>@CDF3KK 8  ? 1 rvV7K7K7=f~7Mpqq q     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' QSY   #!>'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. Trr)r'describe_consumed_topics_with_http_infors r describe_consumed_topicsz!KAFKAApi.describe_consumed_topicszrdrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&describe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method describe_consumed_topicsNzMMissing the required parameter `body` when calling `describe_consumed_topics`rrrr z?/DescribeConsumedTopics/2022-05-01/kafka/post/application_json/r!DescribeConsumedTopicsResponseTr#r)r4s r rz0KAFKAApi.describe_consumed_topics_with_http_infoX +&&&2333,---,--- fX&677  HC*$$:>> thread = api.describe_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_groups_with_http_infors r describe_groupszKAFKAApi.describe_groupsr]rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method describe_groupsNzDMissing the required parameter `body` when calling `describe_groups`rrrr z7/DescribeGroups/2022-05-01/kafka/post/application_json/r!DescribeGroupsResponseTr#r)r4s r rz'KAFKAApi.describe_groups_with_http_infor`rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. Trr)r'describe_instance_detail_with_http_infors r describe_instance_detailz!KAFKAApi.describe_instance_detail< rdrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&describe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method describe_instance_detailNzMMissing the required parameter `body` when calling `describe_instance_detail`rrrr z?/DescribeInstanceDetail/2022-05-01/kafka/post/application_json/r!DescribeInstanceDetailResponseTr#r)r4s r rz0KAFKAApi.describe_instance_detail_with_http_infoQ rrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. Trr)r!describe_instances_with_http_infors r describe_instanceszKAFKAApi.describe_instances s],0'( ::k " " 949$II&II I;T;DKKFKKTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method describe_instancesNzGMissing the required parameter `body` when calling `describe_instances`rrrr z:/DescribeInstances/2022-05-01/kafka/post/application_json/r!DescribeInstancesResponseTr#r)r4s r rz*KAFKAApi.describe_instances_with_http_info sX +&&&2333,---,--- fX&677  HC*$$469:F3KK 8  ? 1 hvV7K7K7=f~7Mfgg g     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' H&   #!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_regions_with_http_infors r describe_regionszKAFKAApi.describe_regions s],0'( ::k " " 747GGGG G9T9$II&IITKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. rrrrrrzBGot an unexpected keyword argument '%s' to method describe_regionsNzEMissing the required parameter `body` when calling `describe_regions`rrrr z8/DescribeRegions/2022-05-01/kafka/post/application_json/r!DescribeRegionsResponseTr#r)r4s r rz(KAFKAApi.describe_regions_with_http_info sX +&&&2333,---,--- fX&677  HC*$$2478F3KK 8  ? 1 fvV7K7K7=f~7Mdee e     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' F   #!3'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. Trr)r(describe_tags_by_resource_with_http_infors r describe_tags_by_resourcez"KAFKAApi.describe_tags_by_resource_ ],0'( ::k " " @4@PPPP PBTB4RR6RRTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a(describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method describe_tags_by_resourceNzNMissing the required parameter `body` when calling `describe_tags_by_resource`rrrr z?/DescribeTagsByResource/2022-05-01/kafka/post/application_json/r!DescribeTagsByResourceResponseTr#r)r4s r rz1KAFKAApi.describe_tags_by_resource_with_http_infot X +&&&2333,---,--- fX&677  HC*$$;=@AF3KK 8  ? 1 ovV7K7K7=f~7Mmnn n     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Mv   #!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a-describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. Trr)r-describe_topic_access_policies_with_http_infors r describe_topic_access_policiesz'KAFKAApi.describe_topic_access_policies s^,0'( ::k " " E4EdUUfUU UGTGWWPVWWTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a<describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. rrrrrrzPGot an unexpected keyword argument '%s' to method describe_topic_access_policiesNzSMissing the required parameter `body` when calling `describe_topic_access_policies`rrrr zD/DescribeTopicAccessPolicies/2022-05-01/kafka/post/application_json/r!#DescribeTopicAccessPoliciesResponseTr#r)r4s r rz6KAFKAApi.describe_topic_access_policies_with_http_info sX +&&&2333,---,--- fX&677  HC*$$@BEFF3KK 8  ? 1 tvV7K7K7=f~7Mrss s     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' RTZ   #!?'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicParametersRequest body: (required) :return: DescribeTopicParametersResponse If the method is called asynchronously, returns the request thread. Trr)r(describe_topic_parameters_with_http_infors r describe_topic_parametersz"KAFKAApi.describe_topic_parameters! rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a*describe_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicParametersRequest body: (required) :return: DescribeTopicParametersResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method describe_topic_parametersNzNMissing the required parameter `body` when calling `describe_topic_parameters`rrrr z@/DescribeTopicParameters/2022-05-01/kafka/post/application_json/r!DescribeTopicParametersResponseTr#r)r4s r rz1KAFKAApi.describe_topic_parameters_with_http_info6 X +&&&2333,---,--- fX&677  HC*$$;=@AF3KK 8  ? 1 ovV7K7K7=f~7Mmnn n     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' NPV   #!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_topic_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_partitions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicPartitionsRequest body: (required) :return: DescribeTopicPartitionsResponse If the method is called asynchronously, returns the request thread. Trr)r(describe_topic_partitions_with_http_infors r describe_topic_partitionsz"KAFKAApi.describe_topic_partitions rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a*describe_topic_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_partitions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicPartitionsRequest body: (required) :return: DescribeTopicPartitionsResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method describe_topic_partitionsNzNMissing the required parameter `body` when calling `describe_topic_partitions`rrrr z@/DescribeTopicPartitions/2022-05-01/kafka/post/application_json/r!DescribeTopicPartitionsResponseTr#r)r4s r rz1KAFKAApi.describe_topic_partitions_with_http_info rrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_topics_with_http_infors r describe_topicszKAFKAApi.describe_topics r]rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method describe_topicsNzDMissing the required parameter `body` when calling `describe_topics`rrrr z7/DescribeTopics/2022-05-01/kafka/post/application_json/r!DescribeTopicsResponseTr#r)r4s r rz'KAFKAApi.describe_topics_with_http_info r`rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_users # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_users(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeUsersRequest body: (required) :return: DescribeUsersResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_users_with_http_infors r describe_userszKAFKAApi.describe_usersD s],0'( ::k " " 545dEEfEE E7T7GGGGTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_users # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_users_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeUsersRequest body: (required) :return: DescribeUsersResponse If the method is called asynchronously, returns the request thread. rrrrrrz@Got an unexpected keyword argument '%s' to method describe_usersNzCMissing the required parameter `body` when calling `describe_users`rrrr z6/DescribeUsers/2022-05-01/kafka/post/application_json/r!DescribeUsersResponseTr#r)r4s r rz&KAFKAApi.describe_users_with_http_infoY sX +&&&2333,---,--- fX&677  HC*$$0256F3KK 8  ? 1 dvV7K7K7=f~7Mbcc c     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Df   #!1'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adisassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r&disassociate_allow_list_with_http_infors r disassociate_allow_listz KAFKAApi.disassociate_allow_list ],0'( ::k " " >4>tNNvNN N@T@PPPPTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"disassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method disassociate_allow_listNzLMissing the required parameter `body` when calling `disassociate_allow_list`rrrr z>/DisassociateAllowList/2022-05-01/kafka/post/application_json/r!DisassociateAllowListResponseTr#r)r4s r rz/KAFKAApi.disassociate_allow_list_with_http_info X +&&&2333,---,--- fX&677  HC*$$9;>?F3KK 8  ? 1 mvV7K7K7=f~7Mkll l     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Lf   #!9'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r modify_allow_list_with_http_infors r modify_allow_listzKAFKAApi.modify_allow_list rOrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a modify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method modify_allow_listNzFMissing the required parameter `body` when calling `modify_allow_list`rrrr z8/ModifyAllowList/2022-05-01/kafka/post/application_json/r!ModifyAllowListResponseTr#r)r4s r rz)KAFKAApi.modify_allow_list_with_http_info rRrc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupRequest body: (required) :return: ModifyGroupResponse If the method is called asynchronously, returns the request thread. Trr)rmodify_group_with_http_infors r modify_groupzKAFKAApi.modify_groupg rVrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amodify_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupRequest body: (required) :return: ModifyGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method modify_groupNzAMissing the required parameter `body` when calling `modify_group`rrrr z4/ModifyGroup/2022-05-01/kafka/post/application_json/r!ModifyGroupResponseTr#r)r4s r rz$KAFKAApi.modify_group_with_http_info| rYrc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. Trr)r)modify_instance_attributes_with_http_infors r modify_instance_attributesz#KAFKAApi.modify_instance_attributes rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a.modify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method modify_instance_attributesNzOMissing the required parameter `body` when calling `modify_instance_attributes`rrrr zA/ModifyInstanceAttributes/2022-05-01/kafka/post/application_json/r! ModifyInstanceAttributesResponseTr#r)r4s r rz2KAFKAApi.modify_instance_attributes_with_http_info X +&&&2333,---,--- fX&677  HC*$$<>ABF3KK 8  ? 1 pvV7K7K7=f~7Mnoo o     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' OQW   #!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a!modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. Trr)r*modify_instance_charge_type_with_http_infors r modify_instance_charge_typez$KAFKAApi.modify_instance_charge_type)rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a0modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method modify_instance_charge_typeNzPMissing the required parameter `body` when calling `modify_instance_charge_type`rrrr zA/ModifyInstanceChargeType/2022-05-01/kafka/post/application_json/r! ModifyInstanceChargeTypeResponseTr#r)r4s r rz3KAFKAApi.modify_instance_charge_type_with_http_info>sX +&&&2333,---,--- fX&677  HC*$$=?BCF3KK 8  ? 1 qvV7K7K7=f~7Mopp p     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' OQW   #!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_instance_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceParametersRequest body: (required) :return: ModifyInstanceParametersResponse If the method is called asynchronously, returns the request thread. Trr)r)modify_instance_parameters_with_http_infors r modify_instance_parametersz#KAFKAApi.modify_instance_parametersrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a.modify_instance_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceParametersRequest body: (required) :return: ModifyInstanceParametersResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method modify_instance_parametersNzOMissing the required parameter `body` when calling `modify_instance_parameters`rrrr zA/ModifyInstanceParameters/2022-05-01/kafka/post/application_json/r! ModifyInstanceParametersResponseTr#r)r4s r rz2KAFKAApi.modify_instance_parameters_with_http_infor rc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. Trr)r#modify_instance_spec_with_http_infors r modify_instance_speczKAFKAApi.modify_instance_specrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amodify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method modify_instance_specNzIMissing the required parameter `body` when calling `modify_instance_spec`rrrr z;/ModifyInstanceSpec/2022-05-01/kafka/post/application_json/r!ModifyInstanceSpecResponseTr#r)r4s r rz,KAFKAApi.modify_instance_spec_with_http_inforDrc rd|d<|dr|j|fi|S|j|fi|}|S)a%modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. Trr)r+modify_topic_access_policies_with_http_infors r modify_topic_access_policiesz%KAFKAApi.modify_topic_access_policiesLrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a4modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. rrrrrrzNGot an unexpected keyword argument '%s' to method modify_topic_access_policiesNzQMissing the required parameter `body` when calling `modify_topic_access_policies`rrrr zB/ModifyTopicAccessPolicies/2022-05-01/kafka/post/application_json/r!!ModifyTopicAccessPoliciesResponseTr#r)r4s r rz4KAFKAApi.modify_topic_access_policies_with_http_infoasX +&&&2333,---,--- fX&677  HC*$$>@CDF3KK 8  ? 1 rvV7K7K7=f~7Mpqq q     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' PRX   #!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_topic_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_attributes(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAttributesRequest body: (required) :return: ModifyTopicAttributesResponse If the method is called asynchronously, returns the request thread. Trr)r&modify_topic_attributes_with_http_infors r modify_topic_attributesz KAFKAApi.modify_topic_attributesrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"modify_topic_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_attributes_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAttributesRequest body: (required) :return: ModifyTopicAttributesResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method modify_topic_attributesNzLMissing the required parameter `body` when calling `modify_topic_attributes`rrrr z>/ModifyTopicAttributes/2022-05-01/kafka/post/application_json/r!ModifyTopicAttributesResponseTr#r)r4s r r"z/KAFKAApi.modify_topic_attributes_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicParametersRequest body: (required) :return: ModifyTopicParametersResponse If the method is called asynchronously, returns the request thread. Trr)r&modify_topic_parameters_with_http_infors r modify_topic_parametersz KAFKAApi.modify_topic_parametersrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"modify_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicParametersRequest body: (required) :return: ModifyTopicParametersResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method modify_topic_parametersNzLMissing the required parameter `body` when calling `modify_topic_parameters`rrrr z>/ModifyTopicParameters/2022-05-01/kafka/post/application_json/r!ModifyTopicParametersResponseTr#r)r4s r r'z/KAFKAApi.modify_topic_parameters_with_http_info#rrc rd|d<|dr|j|fi|S|j|fi|}|S)a modify_user_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_user_authority(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyUserAuthorityRequest body: (required) :return: ModifyUserAuthorityResponse If the method is called asynchronously, returns the request thread. Trr)r$modify_user_authority_with_http_infors r modify_user_authorityzKAFKAApi.modify_user_authorityorkrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amodify_user_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_user_authority_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyUserAuthorityRequest body: (required) :return: ModifyUserAuthorityResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method modify_user_authorityNzJMissing the required parameter `body` when calling `modify_user_authority`rrrr z>> thread = api.query_message_by_timestamp(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. Trr)r)query_message_by_timestamp_with_http_infors r query_message_by_timestampz#KAFKAApi.query_message_by_timestamprrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,query_message_by_timestamp # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_timestamp_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method query_message_by_timestampNzOMissing the required parameter `body` when calling `query_message_by_timestamp`rrrr z@/QueryMessageByTimestamp/2022-05-01/kafka/post/application_json/r!QueryMessageByTimestampResponseTr#r)r4s r r1z2KAFKAApi.query_message_by_timestamp_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)aremove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. Trr)r(remove_tags_from_resource_with_http_infors r remove_tags_from_resourcez"KAFKAApi.remove_tags_from_resource1rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a(remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method remove_tags_from_resourceNzNMissing the required parameter `body` when calling `remove_tags_from_resource`rrrr z?/RemoveTagsFromResource/2022-05-01/kafka/post/application_json/r!RemoveTagsFromResourceResponseTr#r)r4s r r6z1KAFKAApi.remove_tags_from_resource_with_http_infoFrrc rd|d<|dr|j|fi|S|j|fi|}|S)areset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. Trr)r%reset_consumed_offsets_with_http_infors r reset_consumed_offsetszKAFKAApi.reset_consumed_offsetss],0'( ::k " " =4=dMMfMM M?T?OOOOTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)areset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. rrrrrrzHGot an unexpected keyword argument '%s' to method reset_consumed_offsetsNzKMissing the required parameter `body` when calling `reset_consumed_offsets`rrrr z=/ResetConsumedOffsets/2022-05-01/kafka/post/application_json/r!ResetConsumedOffsetsResponseTr#r)r4s r r;z.KAFKAApi.reset_consumed_offsets_with_http_infosX +&&&2333,---,--- fX&677  HC*$$8:=>F3KK 8  ? 1 lvV7K7K7=f~7Mjkk k     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' KV   #!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aupdate_migrate_task_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_migrate_task_status(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateMigrateTaskStatusRequest body: (required) :return: UpdateMigrateTaskStatusResponse If the method is called asynchronously, returns the request thread. Trr)r)update_migrate_task_status_with_http_infors r update_migrate_task_statusz#KAFKAApi.update_migrate_task_statusrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,update_migrate_task_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_migrate_task_status_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateMigrateTaskStatusRequest body: (required) :return: UpdateMigrateTaskStatusResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method update_migrate_task_statusNzOMissing the required parameter `body` when calling `update_migrate_task_status`rrrr z@/UpdateMigrateTaskStatus/2022-05-01/kafka/post/application_json/r!UpdateMigrateTaskStatusResponseTr#r)r4s r r@z2KAFKAApi.update_migrate_task_status_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)averify_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.verify_migrate_sub_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param VerifyMigrateSubTasksRequest body: (required) :return: VerifyMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. Trr)r'verify_migrate_sub_tasks_with_http_infors r verify_migrate_sub_tasksz!KAFKAApi.verify_migrate_sub_tasksTrdrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a$verify_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.verify_migrate_sub_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param VerifyMigrateSubTasksRequest body: (required) :return: VerifyMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method verify_migrate_sub_tasksNzMMissing the required parameter `body` when calling `verify_migrate_sub_tasks`rrrr z>/VerifyMigrateSubTasks/2022-05-01/kafka/post/application_json/r!VerifyMigrateSubTasksResponseTr#r)r4s r rEz0KAFKAApi.verify_migrate_sub_tasks_with_http_infoirgrr)g__name__ __module__ __qualname____doc__r rrrAr@rGrFrNrMrUrTr\r[rcrbrjrirqrprvrur}r|rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrrrrr#r"r(r'r-r,r2r1r7r6r<r;rAr@rFrErr rrs %%%% *J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3J3J3rr)rL __future__rrer,robjectrrMrr rQs'&&&&&  [J3[J3[J3[J3[J3v[J3[J3[J3[J3[J3r