9h $SSKrSSKrSSKrSSKrSSKrSSKJr SSKJrJ r J r SSK J r J r JrJrJrJr SSKJrJrJrJrJrJrJrJrJrJrJr SSKJr SSKJ r SSK!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r. SSK/J0s J1s J2r2 SS K3J4r4J5r5J6r6 SS K7J8r8J9r9 SS K:J;r; S S Kr>J?r?J@r@ S SKAJBrB S SKCJDrD S SKEJFrFJGrGJHrHJIrI SSKJJKrKJLrL S SKMJNrNJOrOJPrPJQrQJRrRJSrSJTrT \RS:a S\VS\W4SjrXO S\VS\Y4SjrX"SS\R5r[S\4S\ \V4Sjr\S\6S\Y4Sjr]S\RS\Y4Sjr_S \YS!\YS\R4S"jr`SAS#\FS$\@S%\ S&\\ \Y4S'jjraS%\ 4S(jrb"S)S*\N5rc"S+S,\O5rdS-\PS.\4S/\S0\QS\4 S1jreS-\PS2\5S3\4S/\9S0\Q4 S4jrfS2\5S/\9S5\4S6jrgS2\5S\R4S7jrhS2\54S8jriS2\5S\ \Y4S9jrjS:\ \YS;\ \YS\k4S<jrlS \YS\k4S=jrmS5\ S>\VS\BR4S?jrn\"5roS5\BRS\ 4S@jrpg)BN)deque)ContextDecimalMAX_PREC)SetListUnionOptionalAnyTuple) descriptor_pb2any_pb2api_pb2 empty_pb2 duration_pb2field_mask_pb2source_context_pb2 struct_pb2 timestamp_pb2type_pb2 wrappers_pb2) json_format)DescriptorPool) calendar_period_pb2 color_pb2date_pb2 datetime_pb2 dayofweek_pb2expr_pb2 fraction_pb2 latlng_pb2 money_pb2 month_pb2postal_address_pb2 timeofday_pb2quaternion_pb2) DescriptorFieldDescriptorFileDescriptor) DecodeErrorMessage)GetMessageClass) _MAGIC_BYTEreference_subject_name_strategytopic_subject_name_strategySchemaRegistryClient) decimal_pb2) RuleRegistry)SchemaSchemaReferenceRuleKindRuleMode)SerializationErrorSerializationContext)BaseSerializerBaseDeserializer RuleContextFieldTransform FieldTypeRuleConditionErrorParsedSchemaCache3vreturnc[U45$zG Convert int to bytes Args: v (int): The int to convert to bytes. )bytesrBs mC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/schema_registry/protobuf.py_bytesrI=saT{c[U5$rE)chrrGs rHrIrIFs 1v rJc$\rSrSrSrSrSrSrg)_ContextStringIOPz9 Wrapper to allow use of StringIO via 'with' constructs. cU$N)selfs rH __enter___ContextStringIO.__enter__Us rJc$UR5 gNF)close)rSargss rH__exit___ContextStringIO.__exit__Xs rJrRN)__name__ __module__ __qualname____firstlineno____doc__rTrZ__static_attributes__rRrJrHrNrNPsrJrNmsg_descc[5nUnSnURbgUnURn[UR5HupVXd:XdM UR U5 Sn O U(d [ S5eURbMgSn[UR R5H)upWXrR:XdMUR U5 Sn O U(d [ S5e[U5$)a& Creates an index array specifying the location of msg_desc in the referenced FileDescriptor. Args: msg_desc (MessageDescriptor): Protobuf MessageDescriptor Returns: list of int: Protobuf MessageDescriptor index array. Raises: ValueError: If the message descriptor is malformed. FTz"Nested MessageDescriptor not foundz#MessageDescriptor not found in file) rcontaining_type enumerate nested_types appendleft ValueErrorfilemessage_types_by_namenamelist)rbmsg_idxcurrentfoundpreviousidxnode msg_type_names rH_create_index_arrayrt]sgGG E  ! ! -**"7#7#78IC""3' 9 AB B  ! ! - E' (K(KL LL (   s #E  M >?? =rJfile_descriptorc`[R"UR5RS5$)z Base64 encode a FileDescriptor Args: file_descriptor (FileDescriptor): FileDescriptor to encode. Returns: str: Base64 encoded FileDescriptor ascii)base64standard_b64encode serialized_pbdecode)rus rH_schema_to_strr|s&  $ $_%B%B C J J7 SSrJfile_descriptor_protoch[R"UR55RS5$)z Base64 encode a FileDescriptorProto Args: file_descriptor_proto (FileDescriptorProto): FileDescriptorProto to encode. Returns: str: Base64 encoded FileDescriptorProto rw)rxrySerializeToStringr{)r}s rH _proto_to_strrs+  $ $%:%L%L%N O V VW^ __rJrk schema_strc[R"URS55n[R"5nUR U5 XlU$![an[[U55eSnAff=f)z Base64 decode a FileDescriptor Args: schema_str (str): Base64 encoded FileDescriptorProto Returns: FileDescriptorProto: schema. rwN) rxstandard_b64decodeencoder FileDescriptorProtoParseFromStringrkr*r8str)rkrrzr}es rH _str_to_protorsp--j.?.?.HIM*>>@)--m<%)" !  ) Q(()sA A8A33A8schemaschema_registry_clientpoolvisitedcUc [5nURbURHn[UR5(dURU;aM/UR UR5 UR UR URSS5n[URXU5 [URURR5nURU5 M gg)a Resolves named schemas referenced by the provided schema recursively. :param schema: Schema to resolve named schemas for. :param schema_registry_client: SchemaRegistryClient to use for retrieval. :param pool: DescriptorPool to add resolved schemas to. :return: DescriptorPool NT serialized) set references _is_builtinrkadd get_versionsubjectversion_resolve_named_schemarrrAdd)rrrrrefreferenced_schemar}s rHrrs% $$$C388$$G(; KK ! 6 B B3;;PSP[P[]aco p  !"3":":44BBC<22@@A9//==>>44BBC:00>>?=33AAB<22@@A.99GGH9//==>8..<<=<22@@A=33AAB8..<<=<22@@A:00>>?9//==>9//==>-88FFG>44BBC=33AAB8..<<=;11??@rJc h^\rSrSrSr/SQrSSSSSS\\SS. rSS\ S \ S \ \ S \ \ S \ \ 4 U4S jjjr\SS\R"S\S\4Sjj5r\SS\R"S\\S\4Sjj5rS\S\S\\4SjrSS\ S\ \S\ \4SjjrS\S\\R@\!44Sjr"Sr#U=r$$) ProtobufSerializera$ Serializer for Protobuf Message derived classes. Serialization format is Protobuf, with Confluent Schema Registry framing. Configuration properties: +-------------------------------------+----------+------------------------------------------------------+ | Property Name | Type | Description | +=====================================+==========+======================================================+ | | | If True, automatically register the configured | | ``auto.register.schemas`` | bool | schema with Confluent Schema Registry if it has | | | | not previously been associated with the relevant | | | | subject (determined via subject.name.strategy). | | | | | | | | Defaults to True. | | | | | | | | Raises SchemaRegistryError if the schema was not | | | | registered against the subject, or could not be | | | | successfully registered. | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether to normalize schemas, which will | | ``normalize.schemas`` | bool | transform schemas to have a consistent format, | | | | including ordering properties and references. | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether to use the given schema ID for | | ``use.schema.id`` | int | serialization. | | | | | +-----------------------------------------+----------+--------------------------------------------------+ | | | Whether to use the latest subject version for | | ``use.latest.version`` | bool | serialization. | | | | | | | | WARNING: There is no check that the latest | | | | schema is backwards compatible with the object | | | | being serialized. | | | | | | | | Defaults to False. | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether to use the latest subject version with | | ``use.latest.with.metadata`` | dict | the given metadata. | | | | | | | | WARNING: There is no check that the latest | | | | schema is backwards compatible with the object | | | | being serialized. | | | | | | | | Defaults to None. | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether or not to skip known types when resolving | | ``skip.known.types`` | bool | schema dependencies. | | | | | | | | Defaults to True. | +-------------------------------------+----------+------------------------------------------------------+ | | | Callable(SerializationContext, str) -> str | | | | | | ``subject.name.strategy`` | callable | Defines how Schema Registry subject names are | | | | constructed. Standard naming strategies are | | | | defined in the confluent_kafka.schema_registry | | | | namespace. | | | | | | | | Defaults to topic_subject_name_strategy. | +-------------------------------------+----------+------------------------------------------------------+ | | | Callable(SerializationContext, str) -> str | | | | | | ``reference.subject.name.strategy`` | callable | Defines how Schema Registry subject names for schema | | | | references are constructed. | | | | | | | | Defaults to reference_subject_name_strategy | +-------------------------------------+----------+------------------------------------------------------+ | ``use.deprecated.format`` | bool | Specifies whether the Protobuf serializer should | | | | serialize message indexes without zig-zag encoding. | | | | This option must be explicitly configured as older | | | | and newer Protobuf producers are incompatible. | | | | If the consumers of the topic being produced to are | | | | using confluent-kafka-python <1.8 then this property | | | | must be set to True until all old consumers have | | | | have been upgraded. | | | | | | | | Warning: This configuration property will be removed | | | | in a future version of the client. | +-------------------------------------+----------+------------------------------------------------------+ Schemas are registered against subject names in Confluent Schema Registry that define a scope in which the schemas can be evolved. By default, the subject name is formed by concatenating the topic name with the message field (key or value) separated by a hyphen. i.e. {topic name}-{message field} Alternative naming strategies may be configured with the property ``subject.name.strategy``. Supported subject name strategies +--------------------------------------+------------------------------+ | Subject Name Strategy | Output Format | +======================================+==============================+ | topic_subject_name_strategy(default) | {topic name}-{message field} | +--------------------------------------+------------------------------+ | topic_record_subject_name_strategy | {topic name}-{record name} | +--------------------------------------+------------------------------+ | record_subject_name_strategy | {record name} | +--------------------------------------+------------------------------+ See `Subject name strategy `_ for additional details. Args: msg_type (Message): Protobuf Message type. schema_registry_client (SchemaRegistryClient): Schema Registry client instance. conf (dict): ProtobufSerializer configuration. See Also: `Protobuf API reference `_ ) _skip_known_types_known_subjects _msg_class _index_array_schema _schema_id_ref_reference_subject_func_use_deprecated_format_parsed_schemasTFN) auto.register.schemasnormalize.schemas use.schema.iduse.latest.versionuse.latest.with.metadataskip.known.typessubject.name.strategyreference.subject.name.strategyuse.deprecated.formatmsg_typerconf rule_conf rule_registrycl>[T U]5 UbSU;a [S5eURR 5nUbUR U5 UR S5Ul[UR[5(d [S5eUR S5Ul [UR[5(d [S5eUR S5Ul URb*[UR[5(d [S5eUR S 5Ul[UR[5(d [S 5eUR(aUR(a [S 5eUR S 5UlURb*[UR[ 5(d [S 5eUR S5Ul[UR"[5(d [S5eUR S5Ul[UR$[5(d [S5eUR$(a[&R("S5 UR S5Ul[-UR*5(d [S5eUR S5Ul[-UR.5(d [S5e[1U5S:a7[SR3SR5UR75555eX lU(aUO[:R<"5UlSUl [C5Ul"Xl#[I5Ul%URLn[OU5Ul([S[UURV5SS9Ul,UR>R[5HInUR]UR8(aUR8R_5O0U(aUO05 MK g)NrzProtobufSerializer: the 'use.deprecated.format' configuration property must be explicitly set due to backward incompatibility with older confluent-kafka-python Protobuf producers and consumers. See the release notes for more detailsrz-auto.register.schemas must be a boolean valuerz)normalize.schemas must be a boolean valuerz"use.schema.id must be an int valuer*use.latest.version must be a boolean valuez?cannot enable both use.latest.version and auto.register.schemasr-use.latest.with.metadata must be a dict valuerz(skip.known.types must be a boolean value-use.deprecated.format must be a boolean valueadProtobufSerializer: the 'use.deprecated.format' configuration property, and the ability to use the old incorrect Protobuf serializer heading format introduced in confluent-kafka-python v1.4.0, will be removed in an upcoming release in 2021 Q2. Please migrate your Python Protobuf producers and consumers to 'use.deprecated.format':False as soon as possibler&subject.name.strategy must be callablerrzUnrecognized properties: {}z, PROTOBUF) schema_type)0super__init__ RuntimeError _default_confcopyupdatepop_auto_register isinstanceboolrh_normalize_schemas_use_schema_idint_use_latest_version_use_latest_with_metadatadictrrwarningswarn_subject_name_funccallablerlenformatjoinkeys _registryr3get_global_instance_rule_registryrrrrr@rrrtrr4r|rir get_executors configureconfig) rSrrrrr conf_copy descriptorrule __class__s rHrProtobufSerializer.__init__zsL  <2$>9: : &&++-     T "'mm,CD$--t44LM M"+--0C"D$11488HI I'mmO<    +t22C88AB B#,==1E#F $22D99IJ J  # #(;(;^_ _)27Q)R&  * * 6t==tDDLM M!*/A!B$00$77GH H&/mm4K&L#$55t<<LM M  & & MM- .#,--0G"H//00EF F+4== -,/(8899EF F y>A :$fTYYy~~/?%@AC C0/>002"(19r ;8rJbufvalzigzagcU(a US-US- - nUS-S:wa0UR[US-S-55 US-nUS-S:waM0UR[U55 g) z Writes val to buf, either using zigzag or uvarint encoding. Args: buf (BytesIO): buffer to write to. val (int): integer to be encoded. zigzag (bool): whether to encode in zigzag or uvarint encoding r-?irN)writerI)rrrs rH _write_varint ProtobufSerializer._write_varintsh !8r *CU{q IIfcDjD01 2 AICU{q  &+rJintsc[U5S:deUS/:XaUR[S55 g[R U[U5US9 UHn[R XUS9 M g)z Encodes each int as a uvarint onto buf Args: buf (BytesIO): buffer to write to. ints ([int]): ints to be encoded. zigzag (bool): whether to encode in zigzag or uvarint encoding rNr)rrrIrr)rrrvalues rH_encode_varints"ProtobufSerializer._encode_varintssf4y1}} A3; IIfTl # ((c$i(GE  , ,S , GrJctx file_descrCc/nURHnUR(a[UR5(aM0UR X5nUR X5n[ [U5USS9nUR(aURRXg5 URRXg5nUR[URUUR55 M U$)z Resolves and optionally registers schema references recursively. Args: ctx (SerializationContext): Serialization context. file_desc (FileDescriptor): file descriptor to traverse. r)rr) dependenciesrrrk_resolve_dependenciesrr4r|rrregister_schema lookup_schemaappendr5r) rSrr schema_refsdepdep_refsrr references rHr(ProtobufSerializer._resolve_dependenciess ))C%%+chh*?*?11#;H66s@GN3/'/(24F""..w?44WEI   sxx/6/8/@/@ B C* rJmessagec ^ Ucg[XR5(d.[SRUR[ U555eUR UUR R5nURUSS9nUbURUl GOX0R;GaURX!R R5n[URR URR"U5UlUR$(a7UR&R)UURUR*5Ul O?UR&R-X0RUR*5RUl URR/U5 UbUR1UR25upgUR5UR65nUR8UR R6m U 4Sjn UR;X#[<R>SUR2USU 5n[A5n U RC[DRF"S[HUR55 URKXRLURN(+S9 U RCURQ55 U RS5sSSS5 $!,(df  g=f)a Serializes an instance of a class derived from Protobuf Message, and prepends it with Confluent Schema Registry framing. Args: message (Message): An instance of a class derived from Protobuf Message. ctx (SerializationContext): Metadata relevant to the serialization. operation. Raises: SerializerError if any error occurs during serialization. Returns: None if messages is None, else a byte array containing the Protobuf serialized message with Confluent Schema Registry framing. Nz!message must be of type {} not {}rfmtc>[UTX!5$rQ transform)rule_ctxfield_transformmsgdescs rH-ProtobufSerializer.__call__..Ts(D#?rJ>bIr)*rrrhrtyperr full_name_get_reader_schema schema_idrrrrir4rrrrrrrrr_get_parsed_schemarFindFileByNamerkrj_execute_rulesr7WRITErNrstructpackr.rrrrgetvalue) rSrrr latest_schemarfd_protorfdfield_transformerfor s @rH__call__ProtobufSerializer.__call__s\& ?'??33@$fT__d7mDF F))#*1*<*<*F*FH//\/J  $+55DO 00 033'',,.J! '' ((DL """&.."@"@AEAEAXAX#Z#'..">">\\4+B+B#DDMI  $ $W -  $!44]5I5IJNH$$X]]3B++G,>,>,C,CDD!A ))#*7*>*>*;=G 2 HHV[[ T__E F  %6%6,0,G,G(G ! I HHW..0 1;;=  s B K K-rc&URRU5nUbU$[5n[U5 [ XR U5 [ SUR5nURU5 URRXU45 XC4$Ndefault rget_parsed_schemarrrrrrrrrSrresultrrs rHr%ProtobufSerializer._get_parsed_schemaf%%77?  M4fnnd; F,=,=>    D)9:~rJ)rrrrrrrrrrrrrrrrr)NNNTrQ)%r\r]r^r_r` __slots__r0r/rr+r1r rr3r staticmethodioBytesIOrrrrrr9r)r5rrFrr4r r rrrra __classcell__rs@rHrrslrf>I "&"#$( !<+J!& M $$(04 Y;Y;!5Y;tn Y; D> Y;  - Y;Y;v2::C$HRZZHtCyH$HH*'! o @F!F!h7K.LF!X`afXgF!P  E.:\:\^l:l4m  rJrc ^\rSrSrSr/SQrSS\SS.rS S\S\ \ S \ \ S \ \ S \ \ 4 U4S jjjr \S!S \R S\S\4Sjj5r\S \R S\4Sj5r\S!S \R S\S\\4Sjj5rS"S\S\ \S\ \4SjjrS\S\\R:\44SjrS\S\ S\\S\!4Sjr"S\#S\$\R:\RJ4S\\S\\#\RJ44Sjr&Sr'U=r($)#ProtobufDeserializerita  Deserializer for Protobuf serialized data with Confluent Schema Registry framing. Args: message_type (Message derived type): Protobuf Message type. conf (dict): Configuration dictionary. ProtobufDeserializer configuration properties: +-------------------------------------+----------+------------------------------------------------------+ | Property Name | Type | Description | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether to use the latest subject version for | | ``use.latest.version`` | bool | deserialization. | | | | | | | | Defaults to False. | +-------------------------------------+----------+------------------------------------------------------+ | | | Whether to use the latest subject version with | | ``use.latest.with.metadata`` | dict | the given metadata. | | | | | | | | Defaults to None. | +-------------------------------------+----------+------------------------------------------------------+ | | | Callable(SerializationContext, str) -> str | | | | | | ``subject.name.strategy`` | callable | Defines how Schema Registry subject names are | | | | constructed. Standard naming strategies are | | | | defined in the confluent_kafka. schema_registry | | | | namespace . | | | | | | | | Defaults to topic_subject_name_strategy. | +-------------------------------------+----------+------------------------------------------------------+ | ``use.deprecated.format`` | bool | Specifies whether the Protobuf deserializer should | | | | deserialize message indexes without zig-zag encoding.| | | | This option must be explicitly configured as older | | | | and newer Protobuf producers are incompatible. | | | | If Protobuf messages in the topic to consume were | | | | produced with confluent-kafka-python <1.8 then this | | | | property must be set to True until all old messages | | | | have been processed and producers have been upgraded.| | | | Warning: This configuration property will be removed | | | | in a future version of the client. | +-------------------------------------+----------+------------------------------------------------------+ See Also: `Protobuf API reference `_ )rrrFN)rrrr message_typerrrrc>[T U]5 X0lU(aUO[R"5Ul[ 5UlSUlUbSU;a [S5eURR5nUbURU5 URS5Ul[UR[ 5(d [#S5eURS5UlUR$b*[UR$[&5(d [#S5eURS5Ul[+UR(5(d [#S5eURS5Ul[UR,[ 5(d [#S 5eUR,(a[.R0"S 5 UR2n[5U5UlUR R95HInUR;UR(aURR=5O0U(aUO05 MK g) NrzProtobufDeserializer: the 'use.deprecated.format' configuration property must be explicitly set due to backward incompatibility with older confluent-kafka-python Protobuf producers and consumers. See the release notes for more detailsrrrrrrrafProtobufDeserializer: the 'use.deprecated.format' configuration property, and the ability to use the old incorrect Protobuf serializer heading format introduced in confluent-kafka-python v1.4.0, will be removed in an upcoming release in 2022 Q2. Please migrate your Python Protobuf producers and consumers to 'use.deprecated.format':False as soon as possible)rrrr3rrr@rrrrrrrrrrrhrrrrrrrrr,rrrr) rSr3rrrrrrrrs rHrProtobufDeserializer.__init__s //9: : &&++-     T "#,==1E#F $22D99IJ J)27Q)R&  * * 6t==tDDLM M"+--0G"H//00EF F&/mm4K&L#$55t<<LM M  & & MM- .",, )*5''557D NNdnn4>>002"(19r ;8rJrrrCcSnSn[RU5nX$S-U--nUS- nUS-(dOM1U(a US- US-*- nU$![a [S5ef=f)z Decodes a single varint from a buffer. Args: buf (BytesIO): buffer to read from zigzag (bool): decode as zigzag or uvarint Returns: int: decoded varint Raises: EOFError: if buffer is empty rrrrr-z"Unexpected EOF while reading index)r2 _read_byteEOFError)rrrshiftis rH_decode_varint#ProtobufDeserializer._decode_varints  A(33C8d(u,, D !|3L A?@ @ As AA A#c\URS5nUS:Xa [S5e[U5$)z Read one byte from buf as an int. Args: buf (BytesIO): The buffer to read from. .. _ord: https://docs.python.org/2/library/functions.html#ord r-rJzUnexpected EOF encountered)readr8ord)rr:s rHr7ProtobufDeserializer._read_bytes- HHQK 878 81v rJc[RXS9nUS:dUS:a [S5eUS:XaS/$/n[U5H&nUR [RUUS95 M( U$)z Read an index array from buf that specifies the message descriptor of interest in the file descriptor. Args: buf (BytesIO): The buffer to read from. Returns: list of int: The index array. rriz$Invalid Protobuf msgidx array length)r2r;r*ranger)rrsize msg_index_s rH_read_index_array&ProtobufDeserializer._read_index_array s$2232F !8tf}DE E 193J tA   1@@HNAP QrJdatarc ^Ucg[U5S:a#[SR[U555eURUS5nSnUbURbUR USS9n[ U5n[R"SURS55upgU[:wa [S5eURXPR(+S 9nURbURRUSS9n URU 5upU RU R 5n UR#XU5n Uc.URX-R$5nUbUR USS9nOSn Sn UbXUR'X9US5nUR(nURUR(5upU RU R 5nOSnU nU nUb:UR#W US /5mUR*R-W R T5mU(a[/W 5"5nUR1UR55 [6R8"US 5nUR;X#UU5n[/T5"5n[6R<"UU5nO0UR?5nUR1UR55 U4S jnURAX#[BRDSUUSU5nUsSSS5 $![2an[[5U55eSnAff=f![2an[[5U55eSnAff=f!,(df  g=f) a Deserialize a serialized protobuf message with Confluent Schema Registry framing. Args: data (bytes): Serialized protobuf message with Confluent Schema Registry framing. ctx (SerializationContext): Metadata relevant to the serialization operation. Returns: Message: Protobuf Message instance. Raises: SerializerError: If there was an error reading the Confluent framing data, or parsing the protobuf serialized message. NzExpecting data framing of length 6 bytes or more but total data size is {} bytes. This message was not produced with a Confluent Schema Registry serializerrrrz]Unknown magic byte. This message was not produced with a Confluent Schema Registry serializerrrTc>[UTX!5$rQr)rr r reader_descs rHr /ProtobufDeserializer.__call__..s(KJrJ)#rr8rrrrrNrunpackr>r.rFr get_schemarrrk_get_message_descr_get_migrationsrrjgetr,rr*rr MessageToDict_execute_migrations ParseDictrrr7READ)rSrHrrrpayloadmagicrrDwriter_schema_rawrr writer_schema writer_desc migrationsreader_schema_raw reader_schemar robj_dictrrMs @rHrProtobufDeserializer.__call__;s9( < t9q=$&BCI&TBSU U ))#t4  4>>#= 33G3NM d #w%}}UGLLOD E #(*FGG..wC^C^?^._I~~)$(NN$=$=i\$=$Z!!%!8!89J!K $ 3 3HMM B "44T)T ?"55c;P;PQG*(,(?(?\(?(Z $(! $ (!11'm]ab $1$8$8!!%!8!89M9M!N $ 3 3HMM B ! $5! - ("44T=1#N +AAEEkFVFVXcd %k245'' 7'44S$?33C*hW%k24!++Hc:oo'5'' 7!L %%cHMM4&7d&79C$ #T#5,SV445#5,SV445m$ #sV7F.M &K=A"M (L#,M = L LL  M # M-MMM  Mrc&URRU5nUbU$[5n[U5 [ XR U5 [ SUR5nURU5 URRXU45 XC4$r"r$r&s rHr'ProtobufDeserializer._get_parsed_schemar)rJrrrDc[R"5nURU5 URSXC5upVURnU(aUS-U-OUnUR U5$)N.)r r CopyToProto_get_message_desc_protopackageFindMessageTypeByName) rSrrrDfile_desc_protor desc_protoriqualified_names rHrQ&ProtobufDeserializer._get_message_descsa)<<> '"&">">r?"^!))6=329)).99rJpathr cUSn[U[R5(a[URUnU(aUS-UR-O URn[ U5S:XaX4$UR XUSS5$URUnU(aUS-UR-O URn[ U5S:XaX4$UR XUSS5$)Nrrfr-)rr rr3rkrrh nested_type)rSror rDindexr s rHrh,ProtobufDeserializer._get_message_desc_protos !  dN>> ? ?##E*C,04#:(chhD9~"y //9QR=I I""5)C,04#:(chhD9~"y //9QR=I IrJ) rrrrrrrrr)NNNNr*rQ))r\r]r^r_r`r+r0rr+r rr1r3rr,r-r.rrr;r7rrFrFr9rr4r r rrrr)r'rQrr DescriptorProtorhrar/r0s@rHr2r2ts.`LI$$(! <; D> <;  - <;<;| ABJJ A A A AD s rzz4494bUb2F)GbS[\cSdbH  E.:\:\^l:l4m  :" :(6 :9 :  :JJN668V8VVWJ9 J sN222 3 JJrJr2rrrr c BUbUcU$[U[5(aUVs/sHn[XXC5PM sn$[U[5(a0UR 5VVs0sHupVU[XXc5_M snn$[U[ 5(a"UR Hn[XXU5 M U$UR5nUbJURRn U (a$[[U 5UR5(d U"XU5$U$s snfs snnfrQ) rrlrritemsr+fields_transform_field current_fieldrtags _disjointr) rrrr itemkeyrr field_ctx rule_tagss rHrrs *,'4  #%#D#4A#% %'4  ")--/3"1JCYsGG"13 3'7####B Sj? K$!!#IHHMM  #i.).. I I"37; ; N%3s D#Drr c URUURUR[U5[ U55 UR b2UR UR5(dUR5 g[X1R5n[U5(aUVs0sHofXV_M nnO/UR[R:XaUVs/sHowPM nn[XXT5nURR[ R":XaUSLa[%UR5eO ['XU5 UR5 gs snfs snf!UR5 f=frW) enter_fieldrrkget_typeget_inline_tagscontaining_oneofHasField exit_fieldgetattr is_map_fieldlabelr(LABEL_REPEATEDrrkindr6 CONDITIONr? _set_field) rrr rr rr}r| new_values rHrxrxs)   LL GG RL B       *73C3CBGG3L3L  )   056%*_E6E XX77 7&+,edTeE,c@ 88==H.. .E!(22" rI . 7, s1A(E<)E%E3%E E#AE EE-rc[U[5(aBURUR5 [ XR5nUR U5 g[U[ 5(aBURUR5 [ XR5nURU5 g[XRU5 grQ) rrl ClearFieldrkrextendrrsetattr)rrr old_values rHrrs%277#GWW-  E4 277#GWW- %(rJc[U5(a[R$UR[R :Xa[R $UR[R:Xa[R$UR[R:Xa[R$UR[R:Xa[R$UR[R[R[R[R [R"4;a[R$$UR[R&[R([R*[R,[R.4;a[R0$UR[R2:Xa[R4$UR[R6:Xa[R8$UR[R::Xa[R<$[R>$rQ) rr>MAPrr( TYPE_MESSAGERECORD TYPE_ENUMENUM TYPE_STRINGSTRING TYPE_BYTESBYTES TYPE_INT32 TYPE_SINT32 TYPE_UINT32 TYPE_FIXED32 TYPE_SFIXED32INT TYPE_INT64 TYPE_SINT64 TYPE_UINT64 TYPE_FIXED64 TYPE_SFIXED64LONG TYPE_FLOATFLOAT TYPE_DOUBLEDOUBLE TYPE_BOOLBOOLEANNULLrs rHrrs{B}} ww/... ww/+++~~ ww/--- ww/,,, ww?--/J/J"..0L0L"0022}} ww?--/J/J"..0L0L"0022~~ ww/,,, ww/--- ww/+++   >>rJcUR[R:H=(a= [URS5=(a URR R $)Noptions)rr(rhasattrr3r map_entryrs rHrr*sD GG33 3 23 2''113rJcUR5R[RnUc [ 5$[ UR 5$rQ) GetOptions Extensionsr field_metarrz)rmetas rHrr0s8 ==? % %h&9&9 :D |u 499~rJtags1tags2c$UH nX!;dM g g)NFTrR)rrtags rHr{r{8s < rJcURS5=(d) URS5=(d URS5$)Nz confluent/zgoogle/protobuf/z google/type/) startswith)rks rHrr?s6 ??< ( + ??- . + ??> *+rJscalec>UR5up#nXA-nUS:a [S5eSnUH nUS-U-nM SU-U-nUR5S-S-nU(aU*nURUSSS9n [R "5n XlSU lXlU $)z Converts a Decimal to a Protobuf value. Args: value (Decimal): The Decimal value to convert. Returns: The Protobuf value. rz)Scale provided does not match the decimal bigT byteordersigned) as_tuplerh bit_lengthto_bytesr2rr precisionr) rrsigndigitsexpdeltaunscaled_datumdigit bytes_reqrFr's rHdecimalToProtobufrEs(D# KE qy 79 9N(2-6Y/N**,q0Q6I (  # #It # LE  "FLFL MrJc[RURSSS9nURS:aUR[lO[ [l[RU5RUR*[5$)z Converts a Protobuf value to Decimal. Args: value (decimal_pb2.Decimal): The Protobuf value to convert. Returns: The Decimal value. rTrr) r from_bytesrrdecimal_contextprecrcreate_decimalscalebr)rrs rHprotobufToDecimalrnse^^EKK5^NN $'  ) ). 9 @ @  o rJrQ)qr-sysrxrr collectionsrdecimalrrrtypingrrr r r r google.protobufr rrrrrrrrrrrgoogle.protobuf.descriptor_poolr google.typerrrrrrr r!r"r#r$r%r&2confluent_kafka.schema_registry.confluent.meta_pb2schema_registry confluentrgoogle.protobuf.descriptorr'r(r)google.protobuf.messager*r+google.protobuf.message_factoryr,rer.r/r0r1confluent.typesr2rr3rr4r5r6r7confluent_kafka.serializationr8r9serder:r;r<r=r>r?r@rrrFrIrr.rNrtr|rrrrrrr2rrxrrrrrr{rrrrrRrJrHrs$ ..99(:6666FE8;BB)'//EEE ;;#%## rzz ***c*Z TN Ts T `)K)K `PS `!!!1S1S!2#' , ,0, ,c#h  ,4A^AB{{| UJ+UJp  ",7:# 0 )1; '5: )? )W )S )Y83_3 CHSXc#h4+c+d+ #W#S#[5H5H#L)[00WrJ