9hSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJr SSK r SSK J r SSK J r SSKJr SSKJr SSKJr SSKJrJrJrJrJrJrJrJrJrJr SS K J!r!J"r" SS K J#r# SS K$J%r% S S K&J'r'J(r( \)r*S\+S\+4Sjr,\R\"\/5r0SS/r1"SS\RdS9r3"SS\35r4"SS\35r5"SS\35r6"SS\75r8"SS \85r9S!\:S\;4S"jr4S'jr?"S(S)\75r@"S*S+\75rA\"S,5rB"S-S.\+\5rC"S/S0\+\5rD\ "S1S255rE\ "S3S49"S5S655rF\ "S7S855rG\ "S9S:55rH\ "S;S<55rI\ "S3S49"S=S>55rJ\ "S3S49"S?S@55rK"SASB\+\5rL\ "SCSD55rM\ "S3S3SE9"SFSG55rN\ "S3S3SE9"SHSI55rOg!\-a \+r*S\+S\+4Sjr,GNf=f)JN)unquoteurlparse)define)field) defaultdict)Enum)Lock) ListDictTypeTypeVarcastOptionalUnionAnyTupleCallable)TTLCacheLRUCache)Response) OAuth2Client)SchemaRegistryErrorOAuthTokenErrorvaluereturnc,[R"USS9$N)safe)urllibquoters {C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/schema_registry/schema_registry_client.py _urlencoder%5s||E++c>[RRUSS9$r)r!parser"r#s r$r%r%:s||!!%b!11r&URL USER_INFOc@\rSrSr\R S\4Sj5rSrg)_BearerFieldProviderArc[eNNotImplementedErrorselfs r$get_bearer_fields&_BearerFieldProvider.get_bearer_fieldsBs!!r&N) __name__ __module__ __qualname____firstlineno__abcabstractmethoddictr4__static_attributes__r6r&r$r,r,As!"4""r&r,) metaclassc8\rSrSrS\S\S\4SjrS\4SjrSrg ) _StaticFieldProviderGtokenlogical_cluster identity_poolc(XlX lX0lgr/rCrDrE)r3rCrDrEs r$__init___StaticFieldProvider.__init__Hs .*r&rcJURURURS.$N)bearer.auth.tokenbearer.auth.logical.clusterbearer.auth.identity.pool.idrGr2s r$r4&_StaticFieldProvider.get_bearer_fieldsMs'%)ZZPTPdPd040B0BD Dr&)rErDrCN) r7r8r9r:strrHr=r4r>r6r&r$rArAGs*+c+C++ D4Dr&rAc@\rSrSrS\\/\4S\4SjrS\4SjrSr g) _CustomOAuthClientRcustom_function custom_configcXlX lgr/rTrU)r3rTrUs r$rH_CustomOAuthClient.__init__Ss.*r&rc8URUR5$r/rWr2s r$r4$_CustomOAuthClient.get_bearer_fieldsWs##D$6$677r&)rUrTN) r7r8r9r:rr r=rHr4r>r6r&r$rRrRRs,+$(>+t+848r&rRcv\rSrSrS\S\S\S\S\S\S\S \S \4S jrS \4S jrS \ 4Sjr S \4Sjr SSjr Sr g) _OAuthClient[ client_id client_secretscopetoken_endpointrDrE max_retriesretries_wait_msretries_max_wait_msc SUlXPlX`l[XUS9UlX@lXplXlXlSUl g)N)r^r_r`g?) rCrDrErclientrarbrcrdtoken_expiry_threshold) r3r^r_r`rarDrErbrcrds r$rH_OAuthClient.__init__\sD .*"Y[`a ,&.#6 &)#r&rcRUR5URURS.$rK)get_access_tokenrDrEr2s r$r4_OAuthClient.get_bearer_fieldshs,%)%:%:%<]a]q]q040B0BD Dr&cURSUR-nURS[R"5U-:$)N expires_in expires_at)rCrgtime)r3 expiry_windows r$ token_expired_OAuthClient.token_expiredls: <043N3NN zz,'$))+ *EEEr&cUR(aUR5(aUR5 URS$)N access_token)rCrqgenerate_access_tokenr2s r$rj_OAuthClient.get_access_tokenqs2zzT//11  & & (zz.))r&Nc [URS-5H-nURRURSS9Ul g g![ avnXR:a$[SURS[U535e[R"[URURU5S- 5 SnAMSnAff=f)Nrclient_credentials)url grant_typezFailed to retrieve token after z attempts due to error: )rangerbrf fetch_tokenrarC ExceptionrrProsleep full_jitterrcrd)r3ies r$ru"_OAuthClient.generate_access_tokenwst''!+,A b![[449L9LYm4n - b(((),KDL\L\K]^DDGF8+MNN ;t';';T=U=UWXY\``aa  bs)A  C A+CC ) rfrErDrbrdrcrCrarg)rN)r7r8r9r:rPintrHr=r4boolrqrjrur>r6r&r$r\r\[sz *# *c *# *WZ *mp * # *25 *HK *be *D4DFtF *#* br&r\c\rSrSrS\4SjrSS\S\\S\4Sjjr S\S \\S\4S jr S\S\4S jr SS\S \\S\4S jjr S r g)_BaseRestClientconfc &UR5nURSS5nUc [S5e[U[5(d [ S[ [U55-5e/nURS5HynUR5RS5nURS5(d0URS5(d[SRU55eURU5 M{ U(d [S5eX@lS UlURS S5nUbX`lURS S5nURS S5nSUlUb UbX4UlUb UcXlUbUc [S 5e[#URS5n [%U R&5[%U R(54n SU;aVU S:wa [S5e[-URSS5RSS55n [/U 5S:wa [S5eU S:waU OSUlSUlURSS5n U bXlSUlURSS5n U bXlSUlURSS5n U bA[U [8[:45(d [ S[ [U 55-5eXlSUlURSS5nUbA[U[8[:45(d [ S[ [U55-5eXlSUlURSS5nUbA[U[8[:45(d [ S [ [U55-5eXlSUl URS!S5nUbB[U[8[:45(d [ S"[ [U55-5eUUl S#Ul!URS$S5nUbB[U[8[:45(d [ S%[ [U55-5eUUl!SUl"SnSnURS&S5Ul#URFGbSUlURFS';aS(S)/nUVs/sH nUU;dM UPM nnU(a)[S*RS+RIU555eURS(5n[U[ 5(d [ S,[ [U55-5eURS)5n[U[ 5(d [ S-[ [U55-5eURFS.:XGa*/S/QnUVs/sH nUU;dM UPM nnU(a)[S0RS+RIU555eURS15Ul%[URJ[5(d*[ S2[ [URJ55-5eURS35Ul&[URL[5(d*[ S4[ [URL55-5eURS55Ul'[URN[5(d*[ S6[ [URN55-5eURS75Ul([URP[5(d*[ S8[ [URP55-5e[SURJURLURNURPUUUR>UR@URB5 Ul"GO}URFS9:XakS:U;a [S;5eURS:5n[UUUU5Ul"[U[5(d [ S<[ [U55-5eGOURFS=:XaS>S?/nUVs/sH nUU;dM UPM nnU(a)[S@RS+RIU555eURS>5n[WU5(d [ SA[ [U55-5eURS?5n[U[X5(d [ SB[ [U55-5e[[UU5Ul"O [SC5e[/U5S:a7[SDRS+RIUR]5555eg![*[ 4a Sn GNf=fs snfs snfs snf)ENryz+Missing required configuration property urlzurl must be a str, not ,/httpmockzInvalid url {}Tzssl.ca.locationzssl.key.locationzssl.certificate.locationzCssl.certificate.location required when configuring ssl.key.locationr)rrzbasic.auth.user.infozbasic.auth.user.info configured with userinfo credentials in the URL. Remove userinfo credentials from the url or remove basic.auth.user.info from the configurationr:rzAbasic.auth.user.info must be in the form of {username}:{password}proxytimeoutr{zcache.capacityz%cache.capacity must be a number, not zcache.latest.ttl.secz+cache.latest.ttl.sec must be a number, not z max.retriesz"max.retries must be a number, not zretries.wait.msz&retries.wait.ms must be a number, not i Nzretries.max.wait.msz*retries.max.wait.ms must be a number, not zbearer.auth.credentials.source> OAUTHBEARER STATIC_TOKENrMrNz4Missing required bearer configuration properties: {}, z#logical cluster must be a str, not z$identity pool id must be a str, not r)bearer.auth.client.idbearer.auth.client.secretbearer.auth.scopebearer.auth.issuer.endpoint.urlz3Missing required OAuth configuration properties: {}rz)bearer.auth.client.id must be a str, not rz-bearer.auth.client.secret must be a str, not rz%bearer.auth.scope must be a str, not rz3bearer.auth.issuer.endpoint.url must be a str, not rrLzMissing bearer.auth.tokenz%bearer.auth.token must be a str, not CUSTOMz$bearer.auth.custom.provider.functionz"bearer.auth.custom.provider.configz:Missing required custom OAuth configuration properties: {}z=bearer.auth.custom.provider.function must be a callable, not z7bearer.auth.custom.provider.config must be a dict, not z+Unrecognized bearer.auth.credentials.sourcezUnrecognized properties: {})/copypop ValueError isinstance string_type TypeErrorrPtypesplitstriprstrip startswithformatappend base_urlsverifycertrrusernamepasswordAttributeErrortuplelenauthrrcache_capacityrfloatcache_latest_ttl_secrbrcrdbearer_field_providerbearer_auth_credentials_sourcejoinr^r_r`rar\rAcallabler=rRkeys)r3r conf_copybase_urlrrycakey client_certparseduserinforrrrrbrcrdrDrEheadersheadermissing_headersproperties_listpropmissing_properties static_tokencustom_bearer_propertiesmissing_custom_propertiesrTrUs r$rH_BaseRestClient.__init__sIIK ==-  JK K(K005DN8KKL L >>#&C))+$$S)C>>&))#..2H2H !1!8!8!=>>   S ! ' JK K" ]],d 3 >K&]]+=tD%.]]3Mt%T 7;  "s$*DI  "s{#I ?{2=> >$..+, 0'&//2JKH "Y .8# "233 Y]]+A2FLLSRSTUH8}! "=>>!)H 4H$   gt,  J -- 40  "L""'7>  %nsEl;; G#dSaNbJc cdd"0 $(!(}}-CTJ  +2S%LAA MPSTXYmTnPo opp(< %mmM48  "kC<88 Ds4P[K\G] ]^^* ##--(94@  &oU|<< H"%d?&;"<!=>>#2D #( 'mm,A4H  *1C<@@ L"%d+>&?"@!ABB':D $%)" .7mm<\^b.c+  . . :DI226UU8:XY8?"[f6QZCZ6"["$%[&,fTYY-G&HJJ#,--0M"N!/377#$ICPTUdPeLf$fgg ) .L M !-55#$JSQUVcQdMe$eff22mC#F7F%`t$V_J_d"%`%$%Z%+VDII6H,I%JLL"+/F!G!$..+>>#$ORUVZ[_[i[iVjRk$kll%.]]3N%O"!$"4"4kBB#$SVYZ^_c_q_qZrVs$stt&]]+>? !$**k::#$KcRVW[WaWaRbNc$cdd&/mm4U&V#!$"5"5{CC#$Y&)$t/B/B*C&D%EFF.:$..$J\J\^b^h^h:>:M:M`m:>:J:JDL`L`:>:R:R.T*44F&i7$%@AA(}}-@A -A,P_an-o*!, <<#$KcRVWcRdNe$eff=44@,R,P,R(>V,p>VdZ^foZoT>V),p,$%a%+VDII6O,P%QSS#,--0V"W00#$c&)$*?&@%ABB!* .R S !-66#$]&)$}*=&>%?@@.@Q^-_* !NOO y>A :$fTYYy~~/?%@AC C i * H X#\ &aH-qs6*e+ f(f f f : ff+ffNryqueryrc[5er/r0r3ryrs r$get_BaseRestClient.getF !##r&bodyc [5er/r0r3ryrkwargss r$post_BaseRestClient.postIrr&c[5er/r0r3rys r$delete_BaseRestClient.deleteLrr&c[5er/r0r3ryrs r$put_BaseRestClient.putOrr&)rrrrrrrr^r_rbrrdrcr`rrarr/)r7r8r9r:r=rHrPrrrrrrr>r6r&r$rrsCTCB$s$8D>$S$$$8D>$$$#$#$$s$(4.$C$$r&rc$^\rSrSrSrS\4U4SjjrS\SS4SjrSS \S \ \S\ 4S jjr S \S \ \S\ 4S jr S \S\ 4Sjr SS \S \ \S\ 4SjjrSS \S\S \ \S \ \S\ 4 SjjrSS\S \S\S\ \S \ \S \ \S\4SjjrSrU=r$) _RestClientiSz HTTP client for Confluent Schema Registry. See SchemaRegistryClient for configuration details. Args: conf (dict): Dictionary containing _RestClient configuration rc>[TU]U5 [R"URUR UR URURS9Ul g)N)rrrrr) superrHhttpxClientrrrrrsession)r3r __class__s r$rH_RestClient.__init__]sC ||;;**LL   r&rrNc4URR5n/SQn/nUHnXR;dM URU5 M U(a)[SR SR U555eSR US5US'USUS'US US 'g) N)rLrNrMzUMissing required bearer auth fields, needs to be set in config or custom function: {}rz Bearer {}rL AuthorizationrNzConfluent-Identity-Pool-IdrMztarget-sr-cluster)rr4rrrr)r3r bearer_fieldsrequired_fieldsmissing_fieldsrs r$handle_bearer_auth_RestClient.handle_bearer_authhs22DDF n$E)%%e,% t$fTYY~%>?A A$/#5#5mDW6X#Y 0=>\0],-'45R'S#$r&ryrc$URUSUS9$)NGET)methodr send_requestrs r$r_RestClient.getys  U% @@r&rc $URUSUS9$)NPOSTrrrrs r$r_RestClient.post|s  V$ ??r&c"URUSS9$)NDELETE)rrrs r$r_RestClient.deletes  X 66r&c$URUSUS9$)NPUTrrrs r$r_RestClient.puts  U >>r&rc |SS0nUb-[R"U5n[[U55SS.nUR(aUR U5 Sn[ UR5H}upxURXX%X45n[UR5(aUR5s $[UR5(aU[UR5S- :Xa OM [URUR5RS5UR5RS55e![a*n U[UR5S- :XaU eSn A GMSn A ff=f![[ ["4a. [URS S [UR$5-5ef=f) a  Sends HTTP request to the SchemaRegistry, trying each base URL in turn. All unsuccessful attempts will raise a SchemaRegistryError with the response contents. In most cases this will be accompanied by a Schema Registry supplied error code. In the event the response is malformed an error_code of -1 will be used. Args: url (str): Request path method (str): HTTP method body (str): Request content query (dict): Query params to attach to the URL Returns: dict: Schema Registry response content. Acceptz]application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/jsonNz&application/vnd.schemaregistry.v1+json)zContent-Lengthz Content-Typer error_codemessagezUnknown Schema Registry Error: )jsondumpsrPrrr enumeratersend_http_request is_success status_code is_retriabler~rrrKeyErrorrcontent) r3ryrrrrresponserrrs r$r_RestClient.send_requests412  ::d#D),SY'OQG  . .  # #G ,$T^^4KA 116DAh2233#==?*#H$8$899Q#dnnBUXYBY=Y>Z5 ?%h&:&:&.mmo&9&9,&G&.mmo&9&9)&DF F  DNN+a//G0 Hn5 ?%h&:&:&(&G(+H,<,<(='>? ? ?s,4N>N9N JJ{4#7#79Q9QSTUX\\ ]-r&)rr/NN)r7r8r9r:__doc__r=rHrrPrrrrrrrrrr> __classcell__)rs@r$rrSs6  T  T$T4T"AsA8D>ASA@@8D>@@7#7#7?s?(4.?C?=A $???? #??+3D>??~?? ??F=A**"%*/2*=Ed^*sm*+3D>* **r&rr c,SUs=:*=(a S:*$s $)Ni+r6r s r$rrs + $ $ $$ $$r&c US;$)N)iiiiiir6rs r$r r s 8 88r& base_delay_ms max_delay_msretries_attemptedcTUSU--n[R"5[X15-$)Ng@)randommin)rrrno_jitter_delays r$rrs(#s.?'?@O ==?S? ??r&c\rSrSrSrSrS\S\SS4SjrSS jr S\S\S \ S4S jr S\SSS \ \4S jr S\SSS \ S 4Sjr S\S\S \ S 4SjrS\S\S \ S 4SjrS\4SjrS\S\4SjrSrSrg) _SchemaCacheiz Thread-safe cache for use with the Schema Registry Client. This cache may be used to retrieve schema ids, schemas or to check known subject membership. c[5Ul[[5Ul[[5Ul[[5Ul[[5Ul[[5Ulgr/) r lockrr=schema_id_index schema_index rs_id_indexrs_version_indexrs_schema_indexr2s r$rH_SchemaCache.__init__sLF *40'-&t, +D 1*40r&subject schema_idschemaSchemacUR X0RUU'X RUU'SSS5 g!,(df  g=f)z Add a Schema identified by schema_id to the cache. Args: subject (str): The subject this schema is associated with schema_id (int): Schema's registration id schema (Schema): Schema instance N)r$r%r&)r3r+r,r-s r$ set_schema_SchemaCache.set_schemas;YY7=  )) 41:  g &v .YYs #9 ARegisteredSchemacBURnURnURnUR XRUU'X@R UU'X R UU'X RUU'X RUU'SSS5 g!,(df  g=f)zq Add a RegisteredSchema to the cache. Args: registered_schema (RegisteredSchema): RegisteredSchema instance N) r+r,versionr$r%r&r'r(r))r3r-registered_schemar+r,r4s r$set_registered_schema"_SchemaCache.set_registered_schema s$++%// #++ YY7=  )) 41:  g &v .3D  W %i 06G ! !' *7 34E  )& 1 YYs AB BrcUR URRU05RUS5sSSS5 $!,(df  g=f)z Get the schema instance associated with schema id from the cache. Args: subject (str): The subject this schema is associated with schema_id (int): Id used to identify a schema Returns: Schema: The schema if known; else None N)r$r%rr3r+r,s r$get_schema_by_id_SchemaCache.get_schema_by_id2s8YY''++GR8<s r$ get_registered_by_subject_schema-_SchemaCache.get_registered_by_subject_schemaRs8YY''++GR8<> --g6ryyA'YYsAF AF (CF  FcTUR URR5 URR5 URR5 UR R5 UR R5 SSS5 g!,(df  g=f)z Clear the cache. N)r$r%clearr&r'r(r)r2s r$rS_SchemaCache.clearso YY  & & (    # # %    " " $  ! ! ' ' )  & & ( YYs BB B')r$r'r)r(r%r&N)r-r.r5r2)r7r8r9r:rrHrPrr0r6rr:r?rBrErHrKrPrSr>r6r&r$r"r"s1;#;#;x; F$NNN@RN HHXH(3-H KKXKRZ[mRnK JCJCJHUgLhJ MMsMxXjOkM 22(BBsB> )r&r"c \rSrSrSrS\4SjrSrSrSr S,S\ S S S \ S \ 4S jjr S,S\ S S S \ S S4SjjrS-S\ S\\ S\\ S S 4SjjrS.S\ S S S \ S\ S S4 SjjrS \\ 4SjrS,S\ S\ S \\ 4SjjrS/S\ S\\ S S4SjjrS0S\ S\\ \ 4S\ S\\ S S4 SjjrS0S\ S\ S\ S\\ S S4 SjjrS\ S \\ 4SjrS,S\ S\ S\ S \ 4SjjrS-S\\ S \\ S \ 4S!jjrS/S\\ S \ 4S"jjrS1S\ S S S\\ \ 4S \ 4S#jjrS-S\\ S$\S%S S%4S&jjrS/S\\ S S%4S'jjr S(r!S)r"\#S\S S4S*j5r$S+r%g)2SchemaRegistryClientiac A Confluent Schema Registry client. Configuration properties (* indicates a required field): +------------------------------+------+-------------------------------------------------+ | Property name | type | Description | +==============================+======+=================================================+ | ``url`` * | str | Comma-separated list of Schema Registry URLs. | +------------------------------+------+-------------------------------------------------+ | | | Path to CA certificate file used | | ``ssl.ca.location`` | str | to verify the Schema Registry's | | | | private key. | +------------------------------+------+-------------------------------------------------+ | | | Path to client's private key | | | | (PEM) used for authentication. | | ``ssl.key.location`` | str | | | | | ``ssl.certificate.location`` must also be set. | +------------------------------+------+-------------------------------------------------+ | | | Path to client's public key (PEM) used for | | | | authentication. | | ``ssl.certificate.location`` | str | | | | | May be set without ssl.key.location if the | | | | private key is stored within the PEM as well. | +------------------------------+------+-------------------------------------------------+ | | | Client HTTP credentials in the form of | | | | ``username:password``. | | ``basic.auth.user.info`` | str | | | | | By default userinfo is extracted from | | | | the URL if present. | +------------------------------+------+-------------------------------------------------+ | | | | | ``proxy`` | str | Proxy such as http://localhost:8030. | | | | | +------------------------------+------+-------------------------------------------------+ | | | | | ``timeout`` | int | Request timeout. | | | | | +------------------------------+------+-------------------------------------------------+ | | | | | ``cache.capacity`` | int | Cache capacity. Defaults to 1000. | | | | | +------------------------------+------+-------------------------------------------------+ | | | | | ``cache.latest.ttl.sec`` | int | TTL in seconds for caching the latest schema. | | | | | +------------------------------+------+-------------------------------------------------+ | | | | | ``max.retries`` | int | Maximum retries for a request. Defaults to 2. | | | | | +------------------------------+------+-------------------------------------------------+ | | | Maximum time to wait for the first retry. | | | | When jitter is applied, the actual wait may | | ``retries.wait.ms`` | int | be less. | | | | | | | | Defaults to 1000. | +------------------------------+------+-------------------------------------------------+ Args: conf (dict): Schema Registry client configuration. See Also: `Confluent Schema Registry documentation `_ rc.Xl[U5Ul[5UlURR nURR nUb![X#5Ul[X#5Ul g[U5Ul[U5Ul gr/) _confr _rest_clientr"_cacherrr_latest_version_cache_latest_with_metadata_cacher)r3rr cache_ttls r$rHSchemaRegistryClient.__init__sy '-"n **99%%::  )1.)LD &/7/RD ,)1.)AD &/7/GD ,r&cU$r/r6r2s r$ __enter__SchemaRegistryClient.__enter__s r&chURb%URRR5 ggr/)rYrclose)r3argss r$__exit__SchemaRegistryClient.__exit__s+    (    % % + + - )r&cUR$r/)rXr2s r$configSchemaRegistryClient.configs zzr& subject_namer-r.normalize_schemasrc>URXU5nUR$) Registers a schema under ``subject_name``. Args: subject_name (str): subject to register a schema under schema (Schema): Schema instance to register normalize_schemas (bool): Normalize schema before registering Returns: int: Schema id Raises: SchemaRegistryError: if Schema violates this subject's Compatibility policy or is otherwise invalid. See Also: `POST Subject API Reference `_ )register_schema_full_responser,)r3rjr-rkr5s r$register_schema$SchemaRegistryClient.register_schemas$.!>>|Ufg ***r&r2cXURRX5nUb [XBUS5$UR5nURR SR [U5U5US9n[RU5nURRXRU5 U$)rmNz!subjects/{}/versions?normalize={}r) rZr?r2to_dictrYrrr% from_dictr0r,)r3rjr-rkr,rr r5s r$rn2SchemaRegistryClient.register_schema_full_response5s.KK00F  #I|TJ J.."$$)) / 6 6z,7OQb c*-66x@ |-H-H&Q  r&Nr,fmtc.URRX!5nUbU$UbSU0OSnUb UbX5S'OSU0nURRSR U5U5n[ R U5nURRX!U5 U$)aR Fetches the schema associated with ``schema_id`` from the Schema Registry. The result is cached so subsequent attempts will not require an additional round-trip to the Schema Registry. Args: schema_id (int): Schema id subject_name (str): Subject name the schema is registered under fmt (str): Format of the schema Returns: Schema: Schema instance identified by the ``schema_id`` Raises: SchemaRegistryError: If schema can't be found. See Also: `GET Schema API Reference `_ Nr+rzschemas/ids/{})rZr:rYrrr.rtr0)r3r,rjrvr-rr s r$ get_schemaSchemaRegistryClient.get_schema]s.--lF  M-9-EL)4 ? "%h!3$$(()9)@)@)KUS!!(+ |? r&deletedcURRX5nUbU$UR5nURR SR [ U5X45US9n[RU5n[URURURUS9nURRX%5 U$)a_ Returns ``schema`` registration information for ``subject``. Args: subject_name (str): Subject name the schema is registered under schema (Schema): Schema instance. normalize_schemas (bool): Normalize schema before registering deleted (bool): Whether to include deleted schemas. Returns: RegisteredSchema: Subject registration information for this schema. Raises: SchemaRegistryError: If schema or subject can't be found See Also: `POST Subject API Reference `_ z#subjects/{}?normalize={}&deleted={}rr)r,r+r4r-) rZrBrsrYrrr%r2rtr,r+r4r6) r3rjr-rkrzr5rr results r$ lookup_schema"SchemaRegistryClient.lookup_schemas.!KKHH^  ($ $.."$$))*O+16*\2JL]+g/6*8"++H5-&&NNNN   ))&D  r&c8URRS5$)aC List all subjects registered with the Schema Registry Returns: list(str): Registered subject names Raises: SchemaRegistryError: if subjects can't be found See Also: `GET subjects API Reference `_ subjects)rYrr2s r$ get_subjects!SchemaRegistryClient.get_subjectss  $$Z00r& permanentcU(aPURRSR[U555nURR U5 U$URRSR[U555nU$)aS Deletes the specified subject and its associated compatibility level if registered. It is recommended to use this API only when a topic needs to be recycled or in development environments. Args: subject_name (str): subject name permanent (bool): True for a hard delete, False (default) for a soft delete Returns: list(int): Versions deleted under this subject Raises: SchemaRegistryError: if the request was unsuccessful. See Also: `DELETE Subject API Reference `_ zsubjects/{}?permanent=truez subjects/{})rYrrr%rZrK)r3rjrversionss r$delete_subject#SchemaRegistryClient.delete_subjectsz( ((//0L17 <8P1QSH KK ) ), 7 ((// 17 <8P1QSHr&c URRUS5nUbU$UbSU0OSnURRSR[ U5S5U5n[ R U5nX0RU'U$)a Retrieves latest registered version for subject Args: subject_name (str): Subject name. fmt (str): Format of the schema Returns: RegisteredSchema: Registration information for this version. Raises: SchemaRegistryError: if the version can't be found or is invalid. See Also: `GET Subject Version API Reference `_ Nrsubjects/{}/versions/{}latest)r[rrYrr%r2rt)r3rjrvr5rr s r$get_latest_version'SchemaRegistryClient.get_latest_versions(!66::<N  ($ $#&?3$$(()B*0&L1I19+;H  <<@@DQ  ($ $7:G3YX_L`}} 7;r4c<URRX5nUbU$UbX4S.OSU0nURRSR [ U5U5U5n[ RU5nURRURU5 U$)a] Retrieves a specific schema registered under ``subject_name``. Args: subject_name (str): Subject name. version (int): version number. Defaults to latest version. deleted (bool): Whether to include deleted schemas. fmt (str): Format of the schema Returns: RegisteredSchema: Registration information for this version. Raises: SchemaRegistryError: if the version can't be found or is invalid. See Also: `GET Subject Version API Reference `_ rrzr) rZrHrYrrr%r2rtr6r-)r3rjr4rzrvr5rr s r$ get_version SchemaRegistryClient.get_version.s.!KKII,`  ($ $7:G3YX_L`$$(()B*0&L1I18+:;@B-66x@ ))*;*B*BDUV  r&chURRSR[U555$)av Get a list of all versions registered with this subject. Args: subject_name (str): Subject name. Returns: list(int): Registered versions Raises: SchemaRegistryError: If subject can't be found See Also: `GET Subject Versions API Reference `_ zsubjects/{}/versions)rYrrr%)r3rjs r$ get_versions!SchemaRegistryClient.get_versionsTs,"  $$%;%B%B:lC[%\]]r&cU(aQURRSR[U5U55nURR X5 U$URRSR[U5U55nU$)a Deletes a specific version registered to ``subject_name``. Args: subject_name (str) Subject name version (int): Version number permanent (bool): True for a hard delete, False (default) for a soft delete Returns: int: Version number which was deleted Raises: SchemaRegistryError: if the subject or version cannot be found. See Also: `Delete Subject Version API Reference `_ z&subjects/{}/versions/{}?permanent=truer)rYrrr%rZrP)r3rjr4rr s r$delete_version#SchemaRegistryClient.delete_versiongs* ((//0X17 <8P8?2ABH KK 1 1, H  ((//0I17 <8P8?2ABHr&levelcUc [S5eUc*URRSSUR50S9$URRSR [ U55SUR50S9$)a. Update global or subject level compatibility level. Args: level (str): Compatibility level. See API reference for a list of valid values. subject_name (str, optional): Subject to update. Sets global compatibility level policy if not set. Returns: str: The newly configured compatibility level. Raises: SchemaRegistryError: If the compatibility level is invalid. See Also: `PUT Subject Compatibility API Reference `_ zlevel must be setrh compatibilityrr config/{})rrYrupperrr%)r3rjrs r$set_compatibility&SchemaRegistryClient.set_compatibilitys* =01 1  $$((/> .N)P P  $$[&,fZ -E&F+:EKKM*J%L Lr&cUbSR[U55nOSnURRU5nUS$)a Get the current compatibility level. Args: subject_name (str, optional): Subject name. Returns global policy if left unset. Returns: str: Compatibility level for the subject if set, otherwise the global compatibility level. Raises: SchemaRegistryError: if the request was unsuccessful. See Also: `GET Subject Compatibility API Reference `_ rrhcompatibilityLevel)rr%rYrr3rjryr|s r$get_compatibility&SchemaRegistryClient.get_compatibilitysF$  #$$Z %=>CC""&&s+*++r&cUR5nURRSR[ U5U5US9nUS$)aTest the compatibility of a candidate schema for a given subject and version Args: subject_name (str): Subject name the schema is registered under schema (Schema): Schema instance. version (int or str, optional): Version number, or the string "latest". Defaults to "latest". Returns: bool: True if the schema is compatible with the specified version Raises: SchemaRegistryError: if the request was unsuccessful. See Also: `POST Test Compatibility API Reference `_ z%compatibility/subjects/{}/versions/{}rr is_compatible)rsrYrrr%)r3rjr-r4rr s r$test_compatibility'SchemaRegistryClient.test_compatibilitysQ*.."$$)) 3 : ::l;SU\ ]dk* ((r&rh ServerConfigcUc [S5eUc(URRSUR5S9$URRSR [ U55UR5S9$)a Update global or subject config. Args: config (ServerConfig): Config. See API reference for a list of valid values. subject_name (str, optional): Subject to update. Sets global config if not set. Returns: str: The newly configured config. Raises: SchemaRegistryError: If the config is invalid. See Also: `PUT Subject Config API Reference `_ zconfig must be setrhrrr)rrYrrsrr%)r3rjrhs r$ set_configSchemaRegistryClient.set_configs0 >12 2  $$((.4nn.>)@ @  $$[&,fZ -E&F*0..*:%< `_ rrh)rr%rYrrrtrs r$ get_configSchemaRegistryClient.get_configsK$  #$$Z %=>CC""&&s+%%f--r&clURR5 URR5 gr/)r[rSr\r2s r$clear_latest_caches(SchemaRegistryClient.clear_latest_cachess& ""((* ((..0r&cURR5 URR5 URR5 gr/)r[rSr\rZr2s r$ clear_caches!SchemaRegistryClient.clear_caches s6 ""((* ((..0 r&cSSKJn URS5nURS5(aU"U5$[ U5$)Nr)MockSchemaRegistryClientryzmock://)mock_schema_registry_clientrrrrV)rrrys r$ new_clientSchemaRegistryClient.new_client%s7Ihhuo >>) $ $+D1 1#D))r&)rZrXr[r\rY)Fr)FFr/)FN)r)&r7r8r9r:rr=rHr`rerhrPrrrornrrxr}r rrrr rrrrrrrrrrrr staticmethodrr>r6r&r$rVrVs?B HT H. #(++)1++ +8#(&!&!)1&!&! &!RX\'',4SM'GOPS}' 'V:?-!-!)1-!-!26-! -!^1d3i1 34DQTI>7;!!!!&.sm!! !!J59&!&!+/S>&!&!$,SM&! &!T59$!$!*-$!$!$,SM$! $!L^^c^&3Z]BLhsmL8TW=LdgL@,hsm,s,8$,)))1)sCx) )<-1+/!<$SM!<(!< !r6r&r$rr1sIIr&rc:\rSrSrSrSrSrSrSrSr S\ 4S jr S r g ) RuleModei9UPGRADE DOWNGRADEUPDOWNREADWRITE WRITEREADrc,[UR5$r/rr2s r$rRuleMode.__str__Arr&r6N) r7r8r9r:rrrrrrrPrr>r6r&r$rr9s,GI F D EIr&rc\rSrSr%\"\SS9r\\\4\ S'S\\\ 44Sjr \ S\ \S\\\ 4S\4S j5rS rS rg ) RuleParamsiEFfactoryhashrrc@0nURUR5 U$r/)updaterr3 field_dicts r$rsRuleParams.to_dictIs%' $++&r&clssrc_dictc2UR5nU"US9nU$)N)rr)rrd rule_paramss r$rtRuleParams.from_dictOs MMOm r&cZ[[URR555$r/)rrrrNr2s r$__hash__RuleParams.__hash__WsIdkk//1233r&r6N)r7r8r9r: _attrs_fieldr=rr rP__annotations__rrs classmethodr rrtrr>r6r&r$rrEsi)$UCFDcNCc3h tAw$sCx.Q4r&rT)frozenc \rSrSr%\\\S'\\\S'\\\S'\\\S'\\\S'\ "SS9r \\ \\S '\\ \S '\\\S '\\\S '\\\S '\\ \S'S\\\44Sjr\S\\S\\\4S\4Sj5rSrg)Rulei[namedockindmoderFrtagsrexpr on_success on_failuredisabledrctURnURnSnURbURRnSnURbURRnUR nUR nSnURbURR5nURnURn URn URn 0n U R05 UbXS'UbX,S'UbXr6r&r$rr[s 3- # 8  8  3- ,% 8D(49 8 Z  3-  tn6c3h6p/tAw/$sCx./Q//r&rc\rSrSr%\"SS9r\\S\S'\"SS9r \\S\S'S\ \ \ 44Sjr \S \\S \ \ \ 4S\4S j5rS rS rg)RuleSetiFrrmigration_rules domain_rulesrc\SnURb6/nURH$nUR5nURU5 M& SnURb6/nURH$nUR5nURU5 M& 0nUR 05 UbXS'UbXGS'U$)NmigrationRules domainRules)rrsrrr)r3_migration_rulesmigration_rules_item_datamigration_rules_item _domain_rulesdomain_rules_item_datadomain_rules_itemrs r$rsRuleSet.to_dicts;?    +! -1-A-A)'@'H'H'J$ ''(<=.B9=    (M*.*;*;&$:$B$B$D!$$%67+<&( "  '+;' (  $(5} %r&rrcdUR5n/nURSS5nU=(d /H)n[RU5nUR U5 M+ /nURSS5nU=(d /H)n [RU 5n UR U 5 M+ U"UUS9n U $)Nr r )rr)rrrrtr) rrrrr r rrrrrrule_sets r$rtRuleSet.from_dicts MMO55!148)9)?R)? %#'>>2K#L  " "#7 8*@ mT2 &3&9r&9 " $/E F     1 2':+%  r&c|[[UR=(d /UR=(d /-55$r/)rrrrr2s r$rRuleSet.__hash__s.It339rd>O>O>USUVWXXr&r6N)r7r8r9r:rrrr rrr rPrrsrr rrtrr>r6r&r$rrs.:.FOXd6l+F+7U+CL(4<(Cc3h0tAw$sCx.Q*Yr&rc\rSrSr%\"\SS9r\\\ \4\ S'S\\\ 44Sjr \ S\\S\\\ 4S\4S j5rS rS rg ) MetadataTagsi FrrrcX0nURR5H up#X1U'M U$r/)rrN)r3r prop_namers r$rsMetadataTags.to_dicts.%' #yy0OI$(y ! 1r&rrcUR5n0nUR5H upE[[[U5nXcU'M" U"US9nU$)N)r)rrNrr rP)rrrrr prop_dicttag metadata_tagss r$rtMetadataTags.from_dictsM MMO$%GGI ItCy),C!O%.  r&cZ[[URR555$r/)rrrrNr2s r$rMetadataTags.__hash__$sIdiioo/011r&r6N)r7r8r9r:rr=rr rPr rrrsrr rrtrr>r6r&r$rr sn!-d!GD$sDI~ Gc3h tAw $sCx. Q  2r&rc\rSrSr%\"\SS9r\\\4\ S'S\\\ 44Sjr \ S\ \S\\\ 4S\4S j5rS rS rg ) MetadataPropertiesi(Fr propertiesrc@0nURUR5 U$r/)rr&rs r$rsMetadataProperties.to_dict,s%' $//*r&rrc2UR5nU"US9nU$)N)r&r)rrrmetadata_propertiess r$rtMetadataProperties.from_dict2s MMO!Q/""r&cZ[[URR555$r/)rrr&rNr2s r$rMetadataProperties.__hash__:sIdoo335677r&r6N)r7r8r9r:rr=r&r rPrrrsrr rrtrr>r6r&r$r%r%(si!-d!GJS#XGc3h #tAw#$sCx.#Q##8r&r%c\rSrSr%\\\S'\\\S'\"SS9r \\ \ \S'S\ \ \ 44Sjr\S \\S \ \ \ 4S\4S j5rS rg )Metadatai>rr&Fr sensitivercBSnURbURR5nSnURbURR5nSnURb&/nURHnUR U5 M 0nUbXS'UbX%S'UbX5S'U$)Nrr&r0)rrsr&r0r)r3_tags _propertiesr0sensitive_itemrs r$rsMetadata.to_dictDs*. 99 II%%'E04 ?? &//113K)- >> %I"&..  0#1&(  !&v   "'2| $  &/{ #r&rrcTUR5nURSS5nSnUb[RU5nURSS5nSnUb[RU5n/nURSS5nU=(d /Hn UR U 5 M U"UUUS9n U $)Nrr&r0)rr&r0)rrrrtr%r) rrrr2rr3r&r0 _sensitiver4rs r$rtMetadata.from_dict]s MMO*+%%*='+  ))%0D01lD0I 37  "+55kBJ UU;- (.B.N   ^ ,/!  r&r6N)r7r8r9r:rrrr%rr0r rPr rrsrr rrtr>r6r&r$r/r/>sz <  +,,%1u%=IxS "=c3h2tAw$sCx.Qr&r/c\rSrSr%\\\S'\\\S'\\\S'S\\\ 44Sjr \ S\ \ S\\\ 4S\ 4S j5rS rg ) SchemaReferenceixrr+r4rc|URnURnURn0nUbXS'UbX$S'UbX4S'U$)Nrr+r4rr+r4)r3rr+r4rs r$rsSchemaReference.to_dict~sRyy,,,,%'  !%v   $+y !  $+y !r&rrcUR5nURSS5nURSS5nURSS5nU"UUUS9nU$)Nrr+r4r<)rr)rrrrr+r4schema_references r$rtSchemaReference.from_dictsY MMOuuVT"%% 4(%% 4(   r&r6N)r7r8r9r:rrPrrr rrsrr rrtr>r6r&r$r:r:xsi 3- c] c]c3h" tAw $sCx. Q  r&r:c>\rSrSrSrSrSrSrSrSr Sr S \ 4S jr S r g ) ConfigCompatibilityLeveliBACKWARDBACKWARD_TRANSITIVEFORWARDFORWARD_TRANSITIVEFULLFULL_TRANSITIVENONErc,[UR5$r/rr2s r$r ConfigCompatibilityLevel.__str__rr&r6N)r7r8r9r:rCrDrErFrGrHrIrPrr>r6r&r$rBrBs3H/G- D'O Dr&rBc\rSrSr%Sr\\\S'Sr\\\S'Sr \\ \S'Sr \\ \S'Sr \\ \S'Sr\\\S'Sr\\\S 'S \\ \44S jr\S \\S \\ \4S \4Sj5rSrg)riNrcompatibility_levelcompatibility_groupdefault_metadataoverride_metadatadefault_rule_setoverride_rule_setrcHSnURbURRnSnURbURRnURn[ UR [ 5(aUR R5nO UR n[ UR[ 5(aURR5nO URn[ UR[5(aURR5nO URn[ UR[5(aURR5nO URn0nUbXS'UbX(S'UbX8S'UbXHS'UbXXS'UbXhS'UbXxS'U$)NrrcompatibilityGroupdefaultMetadataoverrideMetadatadefaultRuleSetoverrideRuleSet) rrrMrNrrOr/rsrPrQrrR) r3_compatibility_compatibility_levelrN_default_metadata_override_metadata_default_rule_set_override_rule_setrs r$rsServerConfig.to_dicts(,    )!//55N.2  # # /#'#;#;#A#A "66 d++X 6 6 $ 5 5 = = ?  $ 5 5  d,,h 7 7!%!7!7!?!?!A !%!7!7  d++W 5 5 $ 5 5 = = ?  $ 5 5  d,,g 6 6!%!7!7!?!?!A !%!7!7 %'  %*8 '  +/C+ ,  */B+ ,  (,=( )  )-?) *  (+<' (  ),>( )r&rrc nUR5nURSS5nUcSnO [U5nURSS5nUcSnO [U5nURSS5nS[S[[ 4SjnU"URSS55n S[S[[ 4Sjn U "URS S55n S[S[[ 4S jn U "URS S55n S[S[[ 4S jnU"URS S55nU"UUUU U U US9nU$)NrrrTdatarctUcU$[U[5(d [5e[R U5$r/rr=rr/rtras r$_parse_default_metadata7ServerConfig.from_dict.._parse_default_metadata2| dD))k!%%d+ +r&rUctUcU$[U[5(d [5e[R U5$r/rcrds r$_parse_override_metadata8ServerConfig.from_dict.._parse_override_metadata rgr&rVctUcU$[U[5(d [5e[R U5$r/rr=rrrtrds r$_parse_default_rule_set7ServerConfig.from_dict.._parse_default_rule_set2| dD))k!$$T* *r&rWctUcU$[U[5(d [5e[R U5$r/rlrds r$_parse_override_rule_set8ServerConfig.from_dict.._parse_override_rule_setror&rX)rrMrNrOrPrQrR)rrrBobjectrr/r)rrrrYrrZrMrNrerOrirPrmrQrqrRrhs r$rtServerConfig.from_dictsX MMO5  ! M4^DM uu%94@  '"& ":;O"P ee$8$? ,& ,Xh5G ,31559JD3QR ,6 ,hx6H ,5QUU;Mt5TU +& +Xg5F +31559I43PQ +6 +hw6G +5QUU;Ld5ST' 3 3-/-/  r&r6)r7r8r9r:rrrBrrMrNrPrOr/rPrQrrRr rrsrr rrtr>r6r&r$rrs8B":;B)-#-+/hx(/,0x)0*.hw'.+/x(/3c3h3j@tAw@$sCx.@Q@@r&r)r cache_hashc\rSrSr%Sr\\\S'Sr\\\S'\ "\ SS9r \\ \ \S'S r\\\S 'S r\\\S 'S \\\44S jr\S\\S\\\4S \4Sj5rSrg )r.i1z An unregistered schema. schema_strAVRO schema_typeFr referencesNrrrcURnURn/nURb4URH$nUR5nUR U5 M& Sn[ UR [5(aUR R5nSn[ UR[5(aURR5n0nUbXS'UbX(S'UbX8S'UbXhS'UbXxS'U$)Nr- schemaTyperzrruleSet) rwryrzrsrrrr/rr) r3r-ry _referencesreferences_item_datareferences_item _metadata _rule_setrs r$rsSchema.to_dict=s&& 68 ?? &(,$"6">">"@""?3)8/3 dmmX . . --/I.2 dmmW - - --/I%'  #)x  "'2| $  "'2| $  %.z "  $-y !r&rrcUR5nURSS5nURSS5n/nURSS5nU=(d /H)n[RU5nUR U5 M+ S[ S[ [4Sjn U "URSS55n S[ S[ [4S jn U "URS S55n U"UUUU U S 9nU$) Nr-r|rxrzrarctUcU$[U[5(d [5e[R U5$r/rcrds r$_parse_metadata)Schema.from_dict.._parse_metadatamrgr&rctUcU$[U[5(d [5e[R U5$r/rlrds r$_parse_rule_set)Schema.from_dict.._parse_rule_setvror&r})rwryrzrr) rrr:rtrrsrr/r) rrrr-ryrzr~rrrrrrs r$rtSchema.from_dict^s MMOx&eeL&1  eeL$/ $/$52$5 -778LMO   o .%6  ,& ,Xh-? ,#155T#:; +& +Xg-> +#155D#9:#!   r&r6)r7r8r9r:rrrPrryrlistrzr r:rr/rrr rrsrr rrtr>r6r&r$r.r.1s !'K#'2>tRW2XJo./X#'Hhx '"&Hhw&c3hB(tAw($sCx.(Q((r&r.c\rSrSr%Sr\\\S'\\\S'\\ \S'\\\S'S\ \ \ 44Sjr \ S \\S \ \ \ 4S\4S j5rS rg )r2iz An registered schema. r,r-r+r4rcURnURnURnURn0nUbUR 5nUbX%S'UbX5S'UbXES'U$)Nidr+r4)r-r,r+r4rs)r3r-r,r+r4rs r$rsRegisteredSchema.to_dictsmNN ,,,,%'  )J  (t   $+y !  $+y !r&rrcUR5n[RU5nURSS5nURSS5nURSS5nU"UUUUS9nU$)Nrr+r4)r,r-r+r4)rr.rtr)rrrr-r,r+r4s r$rtRegisteredSchema.from_dictsj MMO!!!$EE$% %% 4(%% 4(   r&r6N)r7r8r9r:rrrrr.rPr rrsrr rrtr>r6r&r$r2r2s{} V  c] c]c3h*tAw$sCx.Qr&r2)Pr;rloggingrror! urllib.parserrrattrsr _attrs_definerr collectionsrenumr threadingr typingr r r r rrrrrr cachetoolsrrr!authlib.integrations.httpx_clientrerrorrr basestringrrPr% NameError getLoggerr7logVALID_AUTH_PROVIDERSABCMetar,rArRr\rsrrrrrr rrr"rVrrrrrrrr%r/r:rBrr.r2r6r&r$rs$  * )'#000*:7 2K,#,#,!{+"S[[" D/D8-8%b'%bPM$fM$`]/]@%C%D%9c9d9@s@#@#@RW@ )6)Di *6i *X CLsD sD 444*duuup3Y3Y3Yl2228888*d666rd% % % P sD Ddt,UU-Updt,22-2i:2K2#2#22s8 G11HH