9h6SrSSKrSSKrSSKJrJrJrJr SSK J r J r SSK J r JrJrJr SSKJrJrJrJrJrJr SSKJrJrJrJrJr SS KJrJ r J!r!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SS K)J*r*J+r+ SS K,J-r- SSK.J/r0J1r2J3r4 SSK5J6r6J7r7J8r8J9r9J:r:J;rr>J?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrGJHrHJIrIJJrJ SSKKJLrMJNrOJPrQ \RrS"SS\85rVg!\Ta \UrSNf=f)zK Kafka admin client: create, view, alter, and delete topics and resources. N) ConfigSource ConfigEntryConfigResourceAlterConfigOpType) ResourceTypeResourcePatternType) AclOperationAclPermissionType AclBindingAclBindingFilter)BrokerMetadataClusterMetadata GroupMember GroupMetadataPartitionMetadata TopicMetadata)ConsumerGroupListingListConsumerGroupsResultConsumerGroupDescriptionMemberAssignmentMemberDescription)UserScramCredentialAlterationUserScramCredentialUpsertionUserScramCredentialDeletionScramCredentialInfoScramMechanismUserScramCredentialsDescription)TopicDescription)DescribeClusterResult) OffsetSpecListOffsetsResultInfo)DeletedRecords)TopicCollectionConsumerGroupType ElectionType)KafkaException KafkaError_AdminClientImplNewTopic NewPartitionsTopicPartitionCONFIG_SOURCE_UNKNOWN_CONFIG"CONFIG_SOURCE_DYNAMIC_TOPIC_CONFIG#CONFIG_SOURCE_DYNAMIC_BROKER_CONFIG+CONFIG_SOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG"CONFIG_SOURCE_STATIC_BROKER_CONFIGCONFIG_SOURCE_DEFAULT_CONFIGCONFIG_SOURCE_GROUP_CONFIGRESOURCE_UNKNOWN RESOURCE_ANYRESOURCE_TOPICRESOURCE_GROUPRESOURCE_BROKERRESOURCE_TRANSACTIONAL_IDOFFSET_INVALID)ConsumerGroupTopicPartitionsConsumerGroupStateIsolationLevelc^\rSrSrSrU4Sjr\S5r\S5r\S5r \S5r \S5r \S 5r \S 5r \S 5r\S 5r\S 5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5rU4SjrU4SjrU4SjrU4SjrU4SjrU4Sjr U4Sjr!U4Sjr"U4S jr#U4S!jr$U4S"jr%U4S#jr&U4S$jr'U4S%jr(U4S&jr)U4S'jr*U4S(jr+U4S)jr,U4S*jr-S1U4S+jjr.U4S,jr/U4S-jr0U4S.jr1S1U4S/jjr2S0r3U=r4$)2 AdminClient`a9 AdminClient provides admin operations for Kafka brokers, topics, groups, and other resource types supported by the broker. The Admin API methods are asynchronous and return a dict of concurrent.futures.Future objects keyed by the entity. The entity is a topic name for create_topics(), delete_topics(), create_partitions(), and a ConfigResource for alter_configs() and describe_configs(). All the futures for a single API call will currently finish/fail at the same time (backed by the same protocol request), but this might change in future versions of the client. See examples/adminapi.py for example usage. For more information see the `Java Admin API documentation `_. Requires broker version v0.11.0.0 or later. c 0>[[U] "U40UD6 g)a Create a new AdminClient using the provided configuration dictionary. The AdminClient is a standard Kafka protocol client, supporting the standard librdkafka configuration properties as specified at https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md :param dict conf: Configuration properties. At a minimum ``bootstrap.servers`` **should** be set " :param Logger logger: Optional Logger instance to use as a custom log messages handler. N)superr@__init__)selfconfkwargs __class__s cC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/admin/__init__.pyrDAdminClient.__init__vs k4)$9&9cUR5nUR5Hdup4URUS5nUc[SR X155eUbUR [ U55 MSURS5 Mf g![a4nUR5Hup5UR U5 M SnAgSnAff=f)zm Map per-topic results to per-topic futures in futmap. The result value of each (successful) future is None. Nz$Topic {} not found in future-map: {}) resultitemsget RuntimeErrorformat set_exceptionr( set_result Exception)ffutmaprMtopicerrorfutes rI_make_topics_resultAdminClient._make_topics_results  %XXZF &  jj-;&'M'T'TUZ'cdd$%%nU&;<NN4(!/ %$lln !!!$- %sBB C *CC cUR5nUR5Hxup4URUS5nUc[SR X155eUR b&UR [UR 55 MgURU5 Mz g![a4nUR5Hup5UR U5 M SnAgSnAff=f)z Map per-resource results to per-resource futures in futmap. The result value of each (successful) future is a ConfigResource. Nz'Resource {} not found in future-map: {}) rMrNrOrPrQrXrRr(rSrT)rUrVrMresourceconfigsrYrZs rI_make_resource_result!AdminClient._make_resource_results  %XXZF%+\\^!jj40;&'P'W'WX`'ijj>>-%%nX^^&DE NN7+&4 %!' !!!$"0 %sBB C)*CCcgN)rUrVs rI!_make_list_consumer_groups_result-AdminClient._make_list_consumer_groups_results rKcUR5n[UR55n[U5n[U5nXE:wa[ SR XE55e[ U5HKupgX6n[U[5(aUR[U55 M:URU5 MM g![a4n UR5HupURU 5 M Sn A gSn A ff=f)z7 Map per-group results to per-group futures in futmap. 8Results length {} is different from future-map length {}NrMlistvalueslenrPrQ enumerate isinstancer)rRr(rSrTrN rUrVresults futmap_values len_results len_futuresirMrYrZ_s rI_make_consumer_groups_result(AdminClient._make_consumer_groups_results  %hhjG 1Mg,Km,K)"NUUVaoqq&w/ #&fj11%%nV&<=NN6* 0  % ,,.!!!$) %B8B;; C9*C44C9cUR5n[UR55n[U5n[U5nXE:wa[ SR XE55e[ U5HKupgX6n[U[5(aUR[U55 M:URU5 MM g![a4n UR5HupURU 5 M Sn A gSn A ff=f)z Map per-group results to per-group futures in futmap. The result value of each (successful) future is ConsumerGroupTopicPartitions. rhNriros rI#_make_consumer_group_offsets_result/AdminClient._make_consumer_group_offsets_results  %hhjG 1Mg,Km,K)"NUUVaoqq&w/ #&fj11%%nV&<=NN6* 0  % ,,.!!!$) %rxcUR5n[UR55n[U5n[U5nXE:wa[ SR XE55e[ U5HKupgX6n[U[5(aUR[U55 M:URU5 MM g![a4n UR5HupURU 5 M Sn A gSn A ff=f)z Map create ACL binding results to corresponding futures in futmap. For create_acls the result value of each (successful) future is None. For delete_acls the result value of each (successful) future is the list of deleted AclBindings. rhNri) rUrVrprqrrrsrtrMrYrZr^s rI_make_acls_resultAdminClient._make_acls_results %hhjG 1Mg,Km,K)"NUUVaoqq&w/ #&fj11%%nV&<=NN6* 0  %!' !!!$"0 %rxcUR5n[UR55n[U5n[U5nXE:wa[ SR XE55e[ U5HKupgX6n[U[5(aUR[U55 M:URU5 MM g![a4n UR5HupURU 5 M Sn A gSn A ff=f)Nrhriros rI_make_futmap_result_from_list)AdminClient._make_futmap_result_from_lists %hhjG 1Mg,Km,K)"NUUVaoqq&w/ #&fj11%%nV&<=NN6* 0  % ,,.!!!$) %rxcUR5n[U5n[U5n[U5U:wa[SUSU35eUR5HmupVUR US5nUc[SUSU35e[ U[ 5(aUR[U55 M\URU5 Mo g![a4nUR5HupURU5 M SnAgSnAff=f)NzResults length z% is different from future-map length zKey z not found in future-map: ) rMrlrPrNrOrnr)rRr(rSrT) rUrVrprrrskeyvaluerYrZrus rI_make_futmap_resultAdminClient._make_futmap_results %hhjGg,Kf+K7|{*"%k]2WXcWdegg%mmo jjd+;&se#=fXFHHeZ00%%nU&;<NN5). % ,,.!!!$) %sCC D*DDc[RR5nUR5(d [ S5eU$)Nz Future was cancelled prematurely) concurrentfuturesFutureset_running_or_notify_cancelrP)rUs rI_create_futureAdminClient._create_future1s6    % % '--//AB BrKc^^0mUHPnUb3[X15(d#[SR[U555e[R 5TU'MR [R 5nUR UU4Sj5 UT4$)z Create futures and a futuremap for the keys in futmap_keys, and create a request-level future to be bassed to the C API. FIXME: use _make_futures_v2 with TypeError in next major release. Expected list of {}c>T"UT5$rcrdrUrVmake_result_fns rI+AdminClient._make_futures..J nQ&?rK)rn ValueErrorrQreprr@radd_done_callback futmap_keys class_checkrrrUrVs ` @rI _make_futuresAdminClient._make_futures8s{C&z#/K/K !6!=!=d;>O!PQQ%446F3K  & & ( ?@&yrKc^^0mUHPnUb3[X15(d#[SR[U555e[R 5TU'MR [R 5nUR UU4Sj5 UT4$)zz Create futures and a futuremap for the keys in futmap_keys, and create a request-level future to be bassed to the C API. rc>T"UT5$rcrdrs rIr.AdminClient._make_futures_v2..^rrK)rn TypeErrorrQrr@rrrs ` @rI_make_futures_v2AdminClient._make_futures_v2Ns{ C&z#/K/K 5 < .single_future_resultjsu #$++- ' HA!%44u(=>!0 W% #"" #s"8A.A.A.. B8BBc>T"UT5$rcrdrrUrs rIr6AdminClient._make_single_future_pair..ws8LZYZ8[rK)r@rrrs @@rI_make_single_future_pair$AdminClient._make_single_future_pairbs? #  & & ( //1 $$%[\1}rKcB[[U55[U5:g$rc)rlset)rNs rI_has_duplicatesAdminClient._has_duplicateszs3u:#e*,,rKcUc [S5e[U[5(d [S5e[U5S:wa [ S5eUGHn[U[ 5(d [S5eUR c [S5e[UR [5(d [S5eUR (d [ S5eURcM[UR[5(d [S 5e[UR5S :Xa [ S 5eURHnUc [ S 5e[U[5(d [S 5eURc [S5eUR(d [ S5eURS :a [ S5eUR[:wdM[ S5e GM g)Nrequest cannot be Nonerequest must be a listrzECurrently we support listing offsets for a single consumer group only/Expected list of 'ConsumerGroupTopicPartitions''group_id' cannot be None'group_id' must be a string'group_id' cannot be emptyz)'topic_partitions' must be a list or Noner"'topic_partitions' cannot be empty,Element of 'topic_partitions' cannot be None><< !=>>##/!#"6"6==#$OPPs++,1$%IJJ'*';';O&.()WXX%oGG'(fgg&,,4'(opp*00()qrr&0014()qrr&--?()eff(><< !=>>##+ !DEEc22D99 CDD3''(A- !EFF##7"*$%STT!/?CC#$bcc"((0#$kll&,,$%mnn",,q0$jll"))A-$gii$8rKcUcg[U[5(d [S5eUHCnUc [S5e[U[5(d [S5eU(aM:[ S5e g)Nz#Expected input to be list of String'user' cannot be NonezEach value should be a string'user' cannot be empty)rnrjrrr)usersusers rI._check_describe_user_scram_credentials_request:AdminClient._check_describe_user_scram_credentials_requestsh = %&&AB BD| 788dK00 ?@@4 !9:: rKc[U[5(d [S5e[U5S:Xa [ S5eUGH*n[U[ 5(d [S5eUR c [S5e[UR [5(d [S5eUR (d [ S5e[U[5(GaHURc [S5e[UR[5(d [S 5eUR(d [ S 5eURbUR(d [ S 5eUR(a*[UR[5(d [S 5e[UR[5(d [S 5eURRS:a [ S5e[URR[ 5(d [S5eGM[U["5(a-[UR[ 5(d [S5eGM"[S5e g)NzExpected input to be listrz Expected at least one alterationzMExpected each element of list to be subclass of UserScramCredentialAlterationrz'user' must be a stringrz'password' cannot be Nonez'password' must be bytesz'password' cannot be emptyz&'salt' can be None but cannot be emptyz'salt' must be bytesz7Expected credential_info to be ScramCredentialInfo TyperzIterations should be positivez0Expected the mechanism to be ScramMechanism TypezxExpected each element of list 'alterations' to be either a UserScramCredentialUpsertion or a UserScramCredentialDeletion)rnrjrrlrrrrrpasswordbytessaltscram_credential_infor iterations mechanismrr) alterations alterations rI+_check_alter_user_scram_credentials_request7AdminClient._check_alter_user_scram_credentials_requests+t,,78 8 { q ?@ @%Jj*GHH opp& 788joo{;; 9::?? !9::*&BCC&&.#$?@@!*"5"5u==#$>??!**$%ABB??.z$%MNN??:joou+M+M#$:;;!*"B"BDWXX#$]^^33>>B$%DEE!*"B"B"L"Ln]]#$VWW^J(CDD!*"6"6GG#$VWWH !>??C&rKct[U[5(d [S5eUR5Hup#Uc [S5e[U[5(d [S5eUR c [S5e[UR [ 5(d [S5eUR (d [S5eURS:a [S5eUc [S 5e[U[5(aM[S 5e S U;a$[US [5(d [S 5egg) NzdExpected topic_partition_offsets to be dict of [TopicPartitions,OffsetSpec] for list offsets requestzpartition cannot be Nonez"partition must be a TopicPartitionz#partition topic name cannot be Nonez#partition topic name must be stringz$partition topic name cannot be emptyrz$partition index must be non-negativezOffsetSpec cannot be NonezValue must be a OffsetSpecisolation_levelz4isolation_level argument should be an IsolationLevel) rndictrrNrrWrrrr!_IsolationLevel)topic_partition_offsetsrGr offset_specs rI_check_list_offsets_request'AdminClient._check_list_offsets_requests/1488\] ]-D,I,I,K (O& :;;o?? DEE$$, EFFo33[AA EFF"(( !GHH((1, !GHH" ;<<k:66 <==!-L$  &f%67II VWWJ 'rKc.[U[5(d"[S[U5RS35eUHXn[U[ 5(d%[SS[U5RS3-5eUR S:dMO[S5e g)Nz$Expected Request to be a list, got '' za @!ABB' !)_==#$g&,T)_-E-E,Fb$I%JKK&&*$&>?? ( "rKc >[RUVs/sHo3RPM snS[R5upE[[U]"X40UD6 U$s snf)a@ Create one or more new topics. :param list(NewTopic) new_topics: A list of specifictions (NewTopic) for the topics that should be created. :param float operation_timeout: The operation timeout in seconds, controlling how long the CreateTopics request will block on the broker waiting for the topic creation to propagate in the cluster. A value of 0 returns immediately. Default: `socket.timeout.ms/1000.0` :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :param bool validate_only: If true, the request is only validated without creating the topic. Default: False :returns: A dict of futures for each topic, keyed by the topic name. The future result() method returns None. :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. N)r@rrWr[rC create_topics)rE new_topicsrGxrUrVrHs rIrAdminClient.create_topics;sX6 -- .K 1ww .K.2.9.M.MO  k4.zGG /LAc >[RUS[R5up4[[U]"X40UD6 U$)a Delete one or more topics. :param list(str) topics: A list of topics to mark for deletion. :param float operation_timeout: The operation timeout in seconds, controlling how long the DeleteTopics request will block on the broker waiting for the topic deletion to propagate in the cluster. A value of 0 returns immediately. Default: `socket.timeout.ms/1000.0` :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each topic, keyed by the topic name. The future result() method returns None. :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. N)r@rr[rC delete_topics)rEtopicsrGrUrVrHs rIrAdminClient.delete_topics^s@0 --fd.9.M.MO  k4.vCFC rKc,>[[U] "U0UD6$rc)rCr@ list_topicsrEargsrGrHs rIrAdminClient.list_topics}[$3TDVDDrKc,>[[U] "U0UD6$rc)rCr@ list_groupsrs rIrAdminClient.list_groupsrrKc >[RUVs/sHo3RPM snS[R5upE[[U]"X40UD6 U$s snf)a4 Create additional partitions for the given topics. :param list(NewPartitions) new_partitions: New partitions to be created. :param float operation_timeout: The operation timeout in seconds, controlling how long the CreatePartitions request will block on the broker waiting for the partition creation to propagate in the cluster. A value of 0 returns immediately. Default: `socket.timeout.ms/1000.0` :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :param bool validate_only: If true, the request is only validated without creating the partitions. Default: False :returns: A dict of futures for each topic, keyed by the topic name. The future result() method returns None. :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. N)r@rrWr[rCcreate_partitions)rEnew_partitionsrGrrUrVrHs rIr AdminClient.create_partitionssX4 --.O1ww.O.2.9.M.MO  k42>OO /Prc >[RU[[R5up4[[U]"X40UD6 U$)a Get the configuration of the specified resources. :warning: Multiple resources and resource types may be requested, but at most one resource of type RESOURCE_BROKER is allowed per call since these resource requests must be sent to the broker specified in the resource. :param list(ConfigResource) resources: Resources to get the configuration for. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each resource, keyed by the ConfigResource. The type of the value returned by the future result() method is dict(). :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. )r@rrr`rCdescribe_configsrE resourcesrGrUrVrHs rIrAdminClient.describe_configss@2 --i.9.O.OQ  k41)I&I rKc >[R"S[SS9 [R U[ [R 5up4[[U]""X40UD6 U$)aF .. deprecated:: 2.2.0 Update configuration properties for the specified resources. Updates are not transactional so they may succeed for a subset of the provided resources while the others fail. The configuration for a particular resource is updated atomically, replacing the specified values while reverting unspecified configuration entries to their default values. :warning: alter_configs() will replace all existing configuration for the provided resources with the new configuration given, reverting all other configuration for the resource back to their default values. :warning: Multiple resources and resource types may be specified, but at most one resource of type RESOURCE_BROKER is allowed per call since these resource requests must be sent to the broker specified in the resource. :param list(ConfigResource) resources: Resources to update configuration of. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0`. :param bool validate_only: If true, the request is validated only, without altering the configuration. Default: False :returns: A dict of futures for each resource, keyed by the ConfigResource. The future result() method returns None or throws a KafkaException. :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid type. :raises ValueError: Invalid value. zIalter_configs has been deprecated. Use incremental_alter_configs instead.r$)category stacklevel) warningswarnDeprecationWarningr@rrr`rC alter_configsrs rIrAdminClient.alter_configssWJ  W'A 7 --i.9.O.OQ  k4.yFvF rKc >[RU[[R5up4[[U]"X40UD6 U$)aY Update configuration properties for the specified resources. Updates are incremental, i.e only the values mentioned are changed and rest remain as is. :param list(ConfigResource) resources: Resources to update configuration of. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0`. :param bool validate_only: If true, the request is validated only, without altering the configuration. Default: False :param int broker: Broker id to send the request to. When altering broker configurations, it's ignored because the request needs to go to that broker only. Default: controller broker. :returns: A dict of futures for each resource, keyed by the ConfigResource. The future result() method returns None or throws a KafkaException. :rtype: dict() :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid type. :raises ValueError: Invalid value. )r@rrr`rCincremental_alter_configsrs rIr%AdminClient.incremental_alter_configss@4 00N1<1R1RT  k4:9R6R rKc >[RU5(a [S5e[RU[[R 5up4[ [U]"X40UD6 U$)a Create one or more ACL bindings. :param list(AclBinding) acls: A list of unique ACL binding specifications (:class:`.AclBinding`) to create. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each ACL binding, keyed by the :class:`AclBinding` object. The future result() method returns None on success. :rtype: dict[AclBinding, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. z"duplicate ACL bindings not allowed)r@rrrr r}rC create_acls)rEaclsrGrUrVrHs rIrAdminClient.create_aclss]&  & &t , ,AB B--dJ.9.K.KM  k4,T?? rKc Z>[R5n[[U]"X40UD6 U$)a Match ACL bindings by filter. :param AclBindingFilter acl_binding_filter: a filter with attributes that must match. String attributes match exact values or any string if set to None. Enums attributes match exact values or any value if equal to `ANY`. If :class:`ResourcePatternType` is set to :attr:`ResourcePatternType.MATCH` returns ACL bindings with: :attr:`ResourcePatternType.LITERAL` pattern type with resource name equal to the given resource name; :attr:`ResourcePatternType.LITERAL` pattern type with wildcard resource name that matches the given resource name; :attr:`ResourcePatternType.PREFIXED` pattern type with resource name that is a prefix of the given resource name :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A future returning a list(:class:`AclBinding`) as result :rtype: future :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. )r@rrC describe_acls)rEacl_binding_filterrGrUrHs rIr"AdminClient.describe_acls5s-:  & & ( k4./AOOrKc >[RU5(a [S5e[RU[[R 5up4[ [U]"X40UD6 U$)a Delete ACL bindings matching one or more ACL binding filters. :param list(AclBindingFilter) acl_binding_filters: a list of unique ACL binding filters to match ACLs to delete. String attributes match exact values or any string if set to None. Enums attributes match exact values or any value if equal to `ANY`. If :class:`ResourcePatternType` is set to :attr:`ResourcePatternType.MATCH` deletes ACL bindings with: :attr:`ResourcePatternType.LITERAL` pattern type with resource name equal to the given resource name; :attr:`ResourcePatternType.LITERAL` pattern type with wildcard resource name that matches the given resource name; :attr:`ResourcePatternType.PREFIXED` pattern type with resource name that is a prefix of the given resource name :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each ACL binding filter, keyed by the :class:`AclBindingFilter` object. The future result() method returns a list of :class:`AclBinding`. :rtype: dict[AclBindingFilter, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. z)duplicate ACL binding filters not allowed)r@rrrr r}rC delete_acls)rEacl_binding_filtersrGrUrVrHs rIr&AdminClient.delete_aclsXsa:  & &': ; ;HI I--.ACS.9.K.KM  k4,-@NvN rKc >SU;aUSnUbh[U[5(d [S5eUH#n[U[5(aM[S5e UVs/sHo3RPM snUS'UR S5 SU;aUSnUbh[U[5(d [S5eUH#n[U[ 5(aM[S5e UVs/sHoURPM snUS 'UR S5 [R/S[R5upg[[U]."U40UD6 U$s snfs snf) a List consumer groups. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :param set(ConsumerGroupState) states: only list consumer groups which are currently in these states. :param set(ConsumerGroupType) types: only list consumer groups of these types. :returns: a future. Result method of the future returns :class:`ListConsumerGroupsResult`. :rtype: future :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. statesNz'states' must be a setz9All elements of states must be of type ConsumerGroupState states_inttypesz'types' must be a setz7All elements of types must be of type ConsumerGroupType types_int) rnrr_ConsumerGroupStaterpop_ConsumerGroupTyper@rrerClist_consumer_groups) rErGr*stater,rrUrurHs rIr1 AdminClient.list_consumer_groupssD( v H%F!!&#..#$<==#E%e-@AA'(cdd$BH'H 'H|$ JJx f 7OE !%--#$;<<!D%d,>??'(abb"?D&Dedzze&D{# JJw ((T;3`3`a k45aB6B#(I'Es E$Ec >[U[5(d [S5e[U5S:Xa [ S5e[ R US[ R5up4[[ U]&"X40UD6 U$)a Describe consumer groups. :param list(str) group_ids: List of group_ids which need to be described. :param bool include_authorized_operations: If True, fetches group AclOperations. Default: False :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each group, keyed by the group_id. The future result() method returns :class:`ConsumerGroupDescription`. :rtype: dict[str, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. z6Expected input to be list of group ids to be describedrz+Expected at least one group to be describedN) rnrjrrlrr@rrvrCdescribe_consumer_groupsrE group_idsrGrUrVrHs rIr5$AdminClient.describe_consumer_groupssq()T**TU U y>Q JK K--i.9.V.VX  k49)Q&Q rKc >[U[5(d [S5eURn[U[5(d [S5e[ R US[ R5upE[[ U]&"X440UD6 U$)a Describe topics. :param TopicCollection topics: Collection of list of topic names to describe. :param bool include_authorized_operations: If True, fetches topic AclOperations. Default: False :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each topic, keyed by the topic. The future result() method returns :class:`TopicDescription`. :rtype: dict[str, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. z0Expected input to be instance of TopicCollectionz,Expected list of topic names to be describedN) rn_TopicCollectionr topic_namesrjr@rrrCdescribe_topics)rErrGr;rUrVrHs rIr<AdminClient.describe_topicss~(&"233NO O(( +t,,JK K00d1<1Z1Z\  k40J6J rKc Z>[R5n[[U]"U40UD6 U$)aa Describe cluster. :param bool include_authorized_operations: If True, fetches topic AclOperations. Default: False :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A future returning description of the cluster as result :rtype: future containing the description of the cluster in result. :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. )r@rrCdescribe_cluster)rErGrUrHs rIr?AdminClient.describe_clusters,$  & & ( k41!>v>rKc >[U[5(d [S5e[U5S:Xa [ S5e[ R U[[ R5up4[[ U]*"X40UD6 U$)ac Delete the given consumer groups. :param list(str) group_ids: List of group_ids which need to be deleted. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each group, keyed by the group_id. The future result() method returns None. :rtype: dict[str, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. z4Expected input to be list of group ids to be deletedrz)Expected at least one group to be deleted) rnrjrrlrr@rrrvrCdelete_consumer_groupsr6s rIrB"AdminClient.delete_consumer_groups sk$)T**RS S y>Q HI I--ikFnFno  k47 OO rKc >[RU5 [RUVs/sHo3RPM sn[[R 5upE[ [U]"X40UD6 U$s snf)a List offset information for the consumer group and (optional) topic partition provided in the request. :note: Currently, the API supports only a single group. :param list(ConsumerGroupTopicPartitions) list_consumer_group_offsets_request: List of :class:`ConsumerGroupTopicPartitions` which consist of group name and topic partition information for which offset detail is expected. If only group name is provided, then offset information of all the topic and partition associated with that group is returned. :param bool require_stable: If True, fetches stable offsets. Default: False :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each group, keyed by the group id. The future result() method returns :class:`ConsumerGroupTopicPartitions`. :rtype: dict[str, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. )r@rrrrrzrClist_consumer_group_offsets)rE#list_consumer_group_offsets_requestrGrrUrVrHs rIrE'AdminClient.list_consumer_group_offsets(sn4 >>?bc--Or.sOrG/?/?Or.s.9.9.].]_  k4<=`ngmn /tA3c >[RU5 [RUVs/sHo3RPM sn[[R 5upE[ [U]"X40UD6 U$s snf)a Alter offset for the consumer group and topic partition provided in the request. :note: Currently, the API supports only a single group. :param list(ConsumerGroupTopicPartitions) alter_consumer_group_offsets_request: List of :class:`ConsumerGroupTopicPartitions` which consist of group name and topic partition; and corresponding offset to be updated. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures for each group, keyed by the group id. The future result() method returns :class:`ConsumerGroupTopicPartitions`. :rtype: dict[ConsumerGroupTopicPartitions, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. :raises ValueException: Invalid input. )r@rrrrrzrCalter_consumer_group_offsets)rE$alter_consumer_group_offsets_requestrGrrUrVrHs rIrJ(AdminClient.alter_consumer_group_offsetsLsn. ??@de--Os.tOsG/?/?Os.t.9.9.].]_  k4=>bpiop /urHc,>[[U] X5 g)a Sets the SASL credentials used for this client. These credentials will overwrite the old ones, and will be used the next time the client needs to authenticate. This method will not disconnect existing broker connections that have been established with the old credentials. This method is applicable only to SASL PLAIN and SCRAM mechanisms. :param str username: The username to set. :param str password: The password to set. :rtype: None :raises KafkaException: Operation failed locally or on broker. :raises TypeException: Invalid input. N)rCr@set_sasl_credentials)rEusernamerrHs rIrN AdminClient.set_sasl_credentialsms" k45hIrKc >[RU5 Uc[R5up4O'[RUS[R5up4[ [U]"X40UD6 U$)a Describe user SASL/SCRAM credentials. :param list(str) users: List of user names to describe. Duplicate users aren't allowed. Can be None to describe all user's credentials. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: In case None is passed it returns a single future. The future yields a dict[str, UserScramCredentialsDescription] or raises a KafkaException In case a list of user names is passed, it returns a dict[str, future[UserScramCredentialsDescription]]. The futures yield a :class:`UserScramCredentialsDescription` or raise a KafkaException :rtype: Union[future[dict[str, UserScramCredentialsDescription]], dict[str, future[UserScramCredentialsDescription]]] :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. N)r@rrrrrCdescribe_user_scram_credentials)rErrGrret_futrHs rIrR+AdminClient.describe_user_scram_credentialssf4 BB5I ="-"F"F"H J"-">">ud?J?^?^#` J k4@]V\]rKc >[RU5 [R[UVs/sHo3RPM sn5S[R 5upE[ [U]"X40UD6 U$s snf)a Alter user SASL/SCRAM credentials. :param list(UserScramCredentialAlteration) alterations: List of :class:`UserScramCredentialAlteration` to apply. The pair (user, mechanism) must be unique among alterations. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures keyed by user name. The future result() method returns None or raises KafkaException :rtype: dict[str, future] :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. N)r@rrrrrrCalter_user_scram_credentials)rErrGrrUrVrHs rIrV(AdminClient.alter_user_scram_credentialsso( ?? L00Xc5dXc*ooXc5d1egk1<1P1PR  k4=kWPVW 6esA8 c >[RX5 SU;aUSRUS'US UR5VVs/sHBup4[ UR [ UR5[ UR55PMD nnn[RU[[R5upg[[U]2"XV40UD6 U$s snnf)ao Enables to find the beginning offset, end offset as well as the offset matching a timestamp or the offset with max timestamp in partitions. :param dict([TopicPartition, OffsetSpec]) topic_partition_offsets: Dictionary of TopicPartition objects associated with the corresponding OffsetSpec to query for. :param IsolationLevel isolation_level: The isolation level to use when querying. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures keyed by TopicPartition. The future result() method returns ListOffsetsResultInfo raises KafkaException :rtype: dict[TopicPartition, future] :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. risolation_level_value) r@rrrNrrWintr_valuerrrC list_offsets) rErrGrrtopic_partition_offsets_listrUrVrHs rIr\AdminClient.list_offsetss. //0GP  &.45F.G.M.MF* +() 1H0M0M0O(Q1P, O1137P7P3Q 2 23 50O %(Q  001M1@1<1P1PR  k4-.JXQWX (QsA Cc >[RU5 [RU[[R5up4[ [U]"X40UD6 U$)a Deletes all the records before the specified offsets (not including), in the specified topics and partitions. :param list(TopicPartition) topic_partition_offsets: A list of :class:`.TopicPartition` objects having `offset` field set to the offset before which all the records should be deleted. `offset` can be set to :py:const:`OFFSET_END` (-1) to delete all records in the partition. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms/1000.0` :param float operation_timeout: The operation timeout in seconds, controlling how long the `delete_records` request will block on the broker waiting for the record deletion to propagate in the cluster. A value of 0 returns immediately. Default: `socket.timeout.ms/1000.0` :returns: A dict of futures keyed by the :class:`.TopicPartition`. The future result() method returns :class:`.DeletedRecords` or raises :class:`.KafkaException` :rtype: dict[TopicPartition, future] :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. )r@rrrrrCdelete_records)rErrGrUrVrHs rIr`AdminClient.delete_recordssP: ))*AB00 #_k6U6UW  k4/0GUfU rKc >[RX5 [R5n[[U]"UR X$40UD6 U$)aS Perform Preferred or Unclean leader election for all the specified partitions or all partitions in the cluster. :param ElectionType election_type: The type of election to perform. :param List[TopicPartition]|None partitions: The topic partitions to perform the election on. Use ``None`` to perform on all the topic partitions. :param float request_timeout: The overall request timeout in seconds, including broker lookup, request transmission, operation time on broker, and response. Default: `socket.timeout.ms*1000.0` :param float operation_timeout: The operation timeout in seconds, controlling how long the 'elect_leaders' request will block on the broker waiting for the election to propagate in the cluster. A value of 0 returns immediately. Default: `socket.timeout.ms/1000.0` :returns: A future. Method result() of the future returns dict[TopicPartition, KafkaException|None]. :rtype: future :raises KafkaException: Operation failed locally or on broker. :raises TypeError: Invalid input type. :raises ValueError: Invalid input value. )r@rrrC elect_leadersr)rErrrGrUrHs rIrcAdminClient.elect_leaderssC6 ((C  & & ( k4.}/B/BJ\U[\rKrdrc)5r __module__ __qualname____firstlineno____doc__rD staticmethodr[r`rervrzr}rrrrrrrrrrrrrrrrrrr rrrrr"r&r1r5r<r?rBrErJrNrRrVr\r`rc__static_attributes__ __classcell__)rHs@rIr@r@`s7* :%%.%%0  %%0%%2%%2%%*%%* *&.--#g#gJ$i$iL ; ;(?(?TXX6CC ? ?!F>EE D@.`B:!F%N-^B!F0<"HBJ&"H8'R#J!!rKr@)Wrhrconcurrent.futuresr_configrrrr _resourcerr _aclr r r r _metadatarrrrrr_grouprrrrr_scramrrrrrr_topicr_clusterr _listoffsetsr!r"_recordsr#_modelr%r:r&r0r'rcimplr(r)r*r+r,r-rr.r/r0r1r2r3r4r5r6r7r8r9r:r;confluent_kafkar<rr=r.r>r basestringr NameErrorstrr@rdrKrIr}s))-%%'' (( 66'-2%55%%%%%%*&& K O#O Ks4CC  C