9h1RSSKrSSKrSSKrSSKrSSKJr SSKJrJr SSK J r SSK J r \ r/SQr/SQr/S QrS r\R*"\5r"S S \5rg!\a \rN6f=f) N) defaultdict)Sessionutils) ClientError)loads)NONEFULLFORWARDBACKWARD)GETPOSTPUTDELETE)URL USER_INFO SASL_INHERITz]application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/jsonc\rSrSrSrSSjrSrSrSrSr \ S 5r S r \ S 5r \ S 5rS S04Sjr\ S5rSSjrSrSrSrSrSrSrSrSSjrSSjrSSjrSrg) CachedSchemaRegistryClient0a A client that talks to a Schema Registry over HTTP See http://confluent.io/docs/current/schema-registry/docs/intro.html for more information. .. deprecated:: 1.1.0 Use CachedSchemaRegistryClient(dict: config) instead. Existing params ca_location, cert_location and key_location will be replaced with their librdkafka equivalents: `ssl.ca.location`, `ssl.certificate.location` and `ssl.key.location` respectively. The support for password protected private key is via the Config only using 'ssl.key.password' field. Errors communicating to the server will result in a ClientError being raised. :param str|dict url: url(deprecated) to schema registry or dictionary containing client configuration. :param str ca_location: File or directory path to CA certificate(s) for verifying the Schema Registry key. :param str cert_location: Path to client's public key used for authentication. :param str key_location: Path to client's private key used for authentication. Nc Un[U[5(d"UUUUS.n[R"S[SS9 UR SS5n[U[ 5(d [S5eURS5(d [S 5eURS 5Ul [[5Ul [[5Ul[[5Ul[!5nUR S S5nUbXlUR%U5UlUR)URU5Ul[,R."UR5Ul XplUR S S5n U (+UlUR5UR&S UR&SXR*U 5UlUR SS5Ul[;U5S :a([SR=UR?555eg)N)urlssl.ca.locationssl.certificate.locationssl.key.locationaFCachedSchemaRegistry constructor is being deprecated. Use CachedSchemaRegistryClient(dict: config) instead. Existing params ca_location, cert_location and key_location will be replaced with their librdkafka equivalents as keys in the conf dict: `ssl.ca.location`, `ssl.certificate.location` and `ssl.key.location` respectively)category stacklevelrzURL must be of type strhttpz(Invalid URL provided for Schema Registry/rzssl.key.passwordrrzauto.register.schemasTz)Unrecognized configuration properties: {}) isinstancedictwarningswarnDeprecationWarningpop string_type TypeError startswith ValueErrorrstriprrsubject_to_schema_ids id_to_schemasubject_to_schema_versionsrverify_configure_client_tlscert_configure_basic_authauthr urldefragauth_session_is_key_password_provided_make_https_session_https_sessionauto_register_schemaslenformatkeys) selfrmax_schemas_per_subject ca_location cert_location key_locationconfsca_path key_passwords wC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/avro/cached_schema_registry_client.py__init__#CachedSchemaRegistryClient.__init__Es#t$$#.,9$0 D MM2 ,  ; 5hhub!#{++56 6~~f%%GH H::c?&1%6"'-*5d*;' I((,d3  H++D1++DHHd;&&txx0 xx 2D9 -9)9&"66qvvay!&&)WV\V\^jk%)XX.Et%L" t9q=HOOPTPYPYP[\] ] c$UR5 gNcloser>s rG__del__"CachedSchemaRegistryClient.__del__|  rJcU$rLrOs rG __enter__$CachedSchemaRegistryClient.__enter__s rJc$UR5 grLrM)r>argss rG__exit__#CachedSchemaRegistryClient.__exit__rRrJc[US5(aURR5 [US5(aURR 5 gg)Nr6r9)hasattrr6rNr9clearrOs rGrN CachedSchemaRegistryClient.closesD 4 $ $ MM   ! 4) * *    % % ' +rJc@[R"SUXUS9nX5lU$)N CERT_REQUIRED) cert_reqsca_certs cert_filekey_filerF)urllib3 PoolManagerr4)rArB ca_certs_pathr4rF https_sessions rGr8.CachedSchemaRegistryClient._make_https_sessions*++oP]6Ciuw !rJcS[0nURRnU(aA[R"U5R S5n[ [U55US'SUS'USS:wa8USS:wa/UR[R"USS -US-S 95 URU5 URRX!XTS 9nU$) NAcceptzUTF-8Content-Length&application/vnd.schemaregistry.v1+json Content-Typerrr:) basic_auth)headersbody) ACCEPT_HDRr9r4jsondumpsencodestrr;updatere make_headersrequest)r>rmethodrqrrrequest_headersr4responses rG_send_https_session_request6CachedSchemaRegistryClient._send_https_session_requests#Z0""'' ::d#**73D03CIO, -.VON + 7b=T!W]  " "7#7#747S=8rr{rrrqr}_headerss rG _send_request(CachedSchemaRegistryClient._send_requests)  &NUUV\^klm m >>' " "t'E'E77WSH 9zz(--0(//AAj) ),SYH% &'OH^ $ ==((h(R :==?H$8$88 8 9''88 9 :##X%9%99 9 :s$$+D'D+"D('D(+"EEcXnX4U'grLrT)cachesubjectschemavalue sub_caches rG _add_to_cache(CachedSchemaRegistryClient._add_to_cachesN !&rJcX R;aURUnOXRU'U(aCURURX1U5 U(aURURX1U5 gggrL)r.rr-r/)r>r schema_idrversions rG _cache_schema(CachedSchemaRegistryClient._cache_schemasr )) )&&y1F+1  i (    t99&  ;""4#B#B#*G= rJcvURUnURUS5nUbU$SRURSUS/5nS[ U50nUR USUS9upxUS:XdUS :Xa&[ S [ U5-S -[ U5-5eUS :Xa&[ S [ U5-S -[ U5-5eUS:Xa&[ S[ U5-S -[ U5-5eUS:aUS::d&[ S[ U5-S -[ U5-5eUSnURX$U5 U$)a POST /subjects/(string: subject)/versions Register a schema with the registry under the given subject and receive a schema id. avro_schema must be a parsed schema from the python avro library Multiple instances of the same schema will result in cache misses. :param str subject: subject name :param schema avro_schema: Avro schema to be registered :returns: schema_id :rtype: int Nr!subjectsversionsrrr{rr Unauthorized access. Error code:z message:izIncompatible Avro schema:zInvalid Avro schema:+z&Unable to register schema. Error code:idr-getjoinrrwrrr r>r avro_schema schemas_to_idrrrrresultcodes rGregister#CachedSchemaRegistryClient.registerst 227; !%%k48   hh*gzBC#k*+))#f4)H  CK43;@3t9L +,.1&k:; ; S[9CIE +,.1&k:; ; S[4s4y@ +,.1&k:; ;#+$#+FTR +,.1&k:; ;4L  ;7;rJcURUnURUS5nUbU$SRURSU/5nS[ U50nUR USUS9upxUS:XdUS:Xa[ S [ U5-5eUS :Xa[ S [ U5-5eS Us=::aS ::dO [ S[ U5-5eUSnURX$U5 U$)a POST /subjects/(string: subject) Check if a schema has already been registered under the specified subject. If so, returns the schema id. Otherwise, raises a ClientError. avro_schema must be a parsed schema from the python avro library Multiple instances of the same schema will result in inconsistencies. :param str subject: subject name :param schema avro_schema: Avro schema to be checked :returns: schema_id :rtype: int Nr!rrrrrrrzSchema or subject not found:rrz0Unable to check schema registration. Error code:rrrs rGcheck_registration-CachedSchemaRegistryClient.check_registrations 227; !%%k48   hh*g67#k*+))#f4)H  3;$#+@3t9LM M S[rrrrs rGdelete_subject)CachedSchemaRegistryClient.delete_subject7s]hh*g67))#h)?   <CCFKL L rJc XR;aURU$SRURSS[U5/5nUR U5up4US:Xa"[ R S[U5-5 gUS:aUS::d"[ R S [U5-5 gURS 5n[U5nURX15 U$![an[S U<S U<35eSnAff=f) z GET /schemas/ids/{int: id} Retrieve a parsed avro schema by id or None if not found :param int schema_id: int value :returns: Avro schema :rtype: schema r!schemasidsrSchema not found:Nrrz)Unable to get schema for the specific ID:rzReceived bad schema (id z) from registry: ) r.rrrwrlogerrorrrrr)r>rrrr schema_stres rG get_by_id$CachedSchemaRegistryClient.get_by_idHs )) )$$Y/ /hh)UC NCD))#.  3; II)CI5 6#+$#+ IIACIM N H-J dz*""65  d!U^`a"bcc dsC D*C==Dc&URUS5$)aq GET /subjects/(string: subject)/versions/latest Return the latest 3-tuple of: (the schema id, the parsed avro schema, the schema version) for a particular subject. This call always contacts the registry. If the subject is not found, (None,None,None) is returned. :param str subject: subject name :returns: (schema_id, schema, version) :rtype: (string, schema, int) latest)get_by_version)r>rs rGget_latest_schema,CachedSchemaRegistryClient.get_latest_schemahs""7H55rJc SRURSUS[U5/5nURU5upEUS:Xa"[R S[U5-5 gUS:Xa"[R S[U5-5 gUS :aUS ::dgUS nUS nX`R ;aUR UnO[US 5nURXvX5 XgU4$![a ef=f)a GET /subjects/(string: subject)/versions/(versionId: version) Return the 3-tuple of: (the schema id, the parsed avro schema, the schema version) for a particular subject and version. This call always contacts the registry. If the subject is not found, (None,None,None) is returned. :param str subject: subject name :param int version: version number :returns: (schema_id, schema, version) :rtype: (string, schema, int) r!rrrr)NNNrzInvalid version:rrrrr) rrrwrrrr.rrr)r>rrrrrrrs rGr)CachedSchemaRegistryClient.get_by_versionys hh*gz3w<PQ))#.  3; II)CI5 6% S[ II(3t94 5%#+$#+%4L # )) )&&y1F vh/0 6g?7++   s C(( C4cURUnURUS5nUbU$SRURSU/5nS[ U50nUR USUS9upxUS:Xa"[ RS[ U5-5 gUS :aUS ::d"[ RS [ U5-5 gUS n US nURX)X5 U$)z POST /subjects/(string: subject) Get the version of a schema for a given subject. Returns None if not found. :param str subject: subject name :param: schema avro_schema: Avro schema :returns: version :rtype: int Nr!rrrrrz Not found:rrz"Unable to get version of a schema:rr) r/rrrrwrrrr) r>rrschemas_to_versionrrrrrrrs rG get_version&CachedSchemaRegistryClient.get_versions"<rrrrrrrrrs rGtest_compatibility-CachedSchemaRegistryClient.test_compatibilityshh/:w"CL23#k*+ --c&t-LLFs{ :SYFH 7#d)CEzz/22 ?#d)KL  II2A 6 s):C4'CC9!C D%DDcU[;a[S[U5-5eSRURS/5nU(aUSU-- nSU0nUR USUS9upVUS:a US::aUS$[S [U5U4-5e) z PUT /config/(string: subject) Update the compatibility level for a subject. Level must be one of: :param str level: ex: 'NONE','FULL','FORWARD', or 'BACKWARD' zInvalid level specified: %sr!configrrrrrz*Unable to update level: %s. Error code: %d) VALID_LEVELSrrwrrr)r>levelrrrrrrs rGupdate_compatibility/CachedSchemaRegistryClient.update_compatibilitys  $;s5zJK Khh(+,  3= C'))#e$)G  3;43;/* *JcRWjZ^M__` `rJcZSRURS/5nU(aSRX!/5nURU5up4US:=(a US:*nU(d[SU-5eUR SS5nU[ ;aUcSnO [ U5n[S U-5eU$) a# GET /config Get the current compatibility level for a subject. Result will be one of: :param str subject: subject name :raises ClientError: if the request was unsuccessful or an invalid compatibility level was returned :returns: one of 'NONE','FULL','FORWARD', or 'BACKWARD' :rtype: bool r!rrrz3Unable to fetch compatibility level. Error code: %dcompatibilityLevelNzNo compatibility was returnedz(Invalid compatibility level received: %s)rrrrrrrw)r>rrrris_successful_requestrerror_msg_suffixs rGget_compatibility,CachedSchemaRegistryClient.get_compatibilityshh(+, ((C>*C))#.  $ ; $SVZZ[ [ #7>  ,$#B #&}#5 HK[[\ \rJ)r9r7r6r:r.r-r/r)iNNN)NN)rrL)__name__ __module__ __qualname____firstlineno____doc__rHrPrUrYrN staticmethodr8r~r3r1rrrrrrrrrrrrr__static_attributes__rTrJrGrr0s(5^n(   ).D":0"" =*X$L"d@6"',R@@a,rJr)loggingr$rert collectionsrrequestsrrrrrr basestringr( NameErrorrwrrrrs getLoggerrrobjectrrTrJrGrsw, ##K7 0 ;m  !ccKsAA%$A%