9h, SSKrSSKJr SSKJr /SQr"SS\\5r"SS\ 5r "S S \5r "S S \ 5r "S S\ 5r "SS\ 5r"SS\ 5r"SS\ 5r"SS\ 5r"SS\ 5r"SS\ 5rg)N)Enum)KafkaException) DeserializerIntegerDeserializerIntegerSerializerDoubleDeserializerDoubleSerializerStringDeserializerStringSerializer MessageFieldSerializationContextSerializationError Serializerc2\rSrSrSrSrSrSrS\4Sjr Sr g ) r $zz Enum like object for identifying Message fields. Attributes: KEY (str): Message key VALUE (str): Message value nonekeyvaluereturnc,[UR5$N)strr)selfs kC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/serialization/__init__.py__str__MessageField.__str__2s4::N) __name__ __module__ __qualname____firstlineno____doc__NONEKEYVALUErr__static_attributes__rrrr r $s$ D C Err c"\rSrSrSrSSjrSrg)r 6aj SerializationContext provides additional context to the serializer/deserializer about the data it's serializing/deserializing. Args: topic (str): Topic data is being produce to or consumed from. field (MessageField): Describes what part of the message is being serialized. headers (list): List of message header tuples. Defaults to None. Nc(XlX lX0lgr)topicfieldheaders)rr+r,r-s r__init__SerializationContext.__init__Ds   r)r,r-r+r)rr r!r"r#r.r'rrrr r 6s  rr c\rSrSrSrSrg)rJz%Generic error from serializer packagerN)rr r!r"r#r'rrrrrJs/rrc&\rSrSrSr/rSSjrSrg)rOa Extensible class from which all Serializer implementations derive. Serializers instruct Kafka clients on how to convert Python objects to bytes. See built-in implementations, listed below, for an example of how to extend this class. Note: This class is not directly instantiable. The derived classes must be used instead. The following implementations are provided by this module. Note: Unless noted elsewhere all numeric types are signed and serialization is big-endian. .. list-table:: :header-rows: 1 * - Name - Type - Binary Format * - DoubleSerializer - float - IEEE 764 binary64 * - IntegerSerializer - int - int32 * - StringSerializer - unicode - unicode(encoding) Nc[e)a! Converts obj to bytes. Args: obj (object): object to be serialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during serialization Returns: bytes if obj is not None, otherwise None NotImplementedError)robjctxs r__call__Serializer.__call__u ""!rrrrr r!r"r# __slots__r9r'rrrrrOs!FI"rrc&\rSrSrSr/rSSjrSrg)ra Extensible class from which all Deserializer implementations derive. Deserializers instruct Kafka clients on how to convert bytes to objects. See built-in implementations, listed below, for an example of how to extend this class. Note: This class is not directly instantiable. The derived classes must be used instead. The following implementations are provided by this module. Note: Unless noted elsewhere all numeric types are signed and serialization is big-endian. .. list-table:: :header-rows: 1 * - Name - Type - Binary Format * - DoubleDeserializer - float - IEEE 764 binary64 * - IntegerDeserializer - int - int32 * - StringDeserializer - unicode - unicode(encoding) Nc[e)a( Convert bytes to object Args: value (bytes): bytes to be deserialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during deserialization Returns: object if data is not None, otherwise None r5)rrr8s rr9Deserializer.__call__r;rrrr<rrrrrs DI"rrc"\rSrSrSrSSjrSrg)r z Serializes float to IEEE 764 binary64. See Also: `DoubleSerializer Javadoc `_ NcUcg[R"SU5$![Ran[[ U55eSnAff=f)aS Args: obj (object): object to be serialized ctx (SerializationContext): Metadata pertaining to the serialization operation Note: None objects are represented as Kafka Null. Raises: SerializerError if an error occurs during serialization. Returns: IEEE 764 binary64 bytes if obj is not None, otherwise None N>d_structpackerrorrrrr7r8es rr9DoubleSerializer.__call__sE$ ; -<<c* *}} -$SV, , -A AA rrrr r!r"r#r9r'rrrr r s -rr c"\rSrSrSrSSjrSrg)rz Deserializes float to IEEE 764 binary64. See Also: `DoubleDeserializer Javadoc `_ NcUcg[R"SU5S$![Ran[[ U55eSnAff=f)aA Deserializes float from IEEE 764 binary64 bytes. Args: value (bytes): bytes to be deserialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during deserialization. Returns: float if data is not None, otherwise None NrErrGunpackrIrrrrr8rKs rr9DoubleDeserializer.__call__J" = ->>$.q1 1}} -$SV, , - A AA rrrNrrrrr -rrc"\rSrSrSrSSjrSrg)riz Serializes int to int32 bytes. See Also: `IntegerSerializer Javadoc `_ NcUcg[R"SU5$![Ran[[ U55eSnAff=f)aa Serializes int as int32 bytes. Args: obj (object): object to be serialized ctx (SerializationContext): Metadata pertaining to the serialization operation Note: None objects are represented as Kafka Null. Raises: SerializerError if an error occurs during serialization Returns: int32 bytes if obj is not None, else None N>irFrJs rr9IntegerSerializer.__call__sE( ; -<<c* *}} -$SV, , -rMrrrNrrrrrs -rrc"\rSrSrSrSSjrSrg)ri-z Deserializes int to int32 bytes. See Also: `IntegerDeserializer Javadoc `_ NcUcg[R"SU5S$![Ran[[ U55eSnAff=f)a1 Deserializes int from int32 bytes. Args: value (bytes): bytes to be deserialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during deserialization. Returns: int if data is not None, otherwise None Nr[rrRrTs rr9IntegerDeserializer.__call__5rVrWrrrNrrrrr-rXrrc,\rSrSrSrSSjrSSjrSrg) r iOa Serializes unicode to bytes per the configured codec. Defaults to ``utf_8``. Note: None objects are represented as Kafka Null. Args: codec (str, optional): encoding scheme. Defaults to utf_8 See Also: `Supported encodings `_ `StringSerializer Javadoc `_ cXlgrcodecrrcs rr.StringSerializer.__init___ rNcUcgURUR5$![Ran[ [ U55eSnAff=f)a Serializes a str(py2:unicode) to bytes. Compatibility Note: Python 2 str objects must be converted to unicode objects. Python 3 all str objects are already unicode objects. Args: obj (object): object to be serialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during serialization. Returns: serialized bytes if obj is not None, otherwise None N)encodercrGrIrrrJs rr9StringSerializer.__call__bsG* ; -::djj) )}} -$SV, , -!AA  Arbutf_8rrr r!r"r#r.r9r'rrrr r Os -rr c,\rSrSrSrSSjrSSjrSrg) r iaq Deserializes a str(py2:unicode) from bytes. Args: codec (str, optional): encoding scheme. Defaults to utf_8 See Also: `Supported encodings `_ `StringDeserializer Javadoc `_ cXlgrrbrds rr.StringDeserializer.__init__rfrNcUcgURUR5$![Ran[ [ U55eSnAff=f)a$ Serializes unicode to bytes per the configured codec. Defaults to ``utf_8``. Compatibility Note: Python 2 str objects must be converted to unicode objects by the application prior to using this serializer. Python 3 all str objects are already unicode objects. Args: value (bytes): bytes to be deserialized ctx (SerializationContext): Metadata pertaining to the serialization operation Raises: SerializerError if an error occurs during deserialization. Returns: unicode if data is not None, otherwise None N)decodercrGrIrrrTs rr9StringDeserializer.__call__sG. = -<< + +}} -$SV, , -rjrbrkrrmrrrr r s -rr )structrGenumrconfluent_kafka.errorr__all__rr objectr rrrr rrrr r rrrrys$0 3$6(  7"7"t6"66"r!-z!-H--D"- "-J-,-D.-z.-b----r