9hSSKJrJr SSKJr "SS\5r"SS\5r"SS\\5r"S S \\5r"S S \5r "S S\ \5r "SS\ \5r g))KafkaException KafkaError)SerializationErrorcP^\rSrSrSrSU4Sjjr\S5r\S5rSr U=r $)_KafkaClientErrorz Wraps all errors encountered by a Kafka Client Args: kafka_error (KafkaError): KafkaError instance. exception(Exception, optional): The original exception kafka_message (Message, optional): The Kafka Message returned by the broker. cD>[[U] U5 X lX0lgN)superr__init__ exception kafka_messageself kafka_errorr r __class__s ZC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/error.pyr _KafkaClientError.__init__#s / <"*c<URSR5$Nr)argscoders rr_KafkaClientError.code(yy|  ""rc<URSR5$r)rnamers rr_KafkaClientError.name,rrr rNN) __name__ __module__ __qualname____firstlineno____doc__r propertyrr__static_attributes__ __classcell__rs@rrrs5 + ####rrc0^\rSrSrSrSU4SjjrSrU=r$) ConsumeError1a Wraps all errors encountered during the consumption of a message. Note: In the event of a serialization error the original message contents may be retrieved from the ``kafka_message`` attribute. Args: kafka_error (KafkaError): KafkaError instance. exception(Exception, optional): The original exception kafka_message (Message, optional): The Kafka Message returned by the broker. c.>[[U] XU5 gr )r r,r rs rr ConsumeError.__init__Cs lD*;=Qrr!r"r#r$r%r&r r(r)r*s@rr,r,1s"RRrr,c0^\rSrSrSrSU4SjjrSrU=r$)KeyDeserializationErrorGz Wraps all errors encountered during the deserialization of a Kafka Message's key. Args: exception(Exception, optional): The original exception kafka_message (Message, optional): The Kafka Message returned by the broker. cl>[[U] [[R[ U55XS9 gNr )r r3r r_KEY_DESERIALIZATIONstrrr rrs rr KeyDeserializationError.__init__Ts/ %t5 z66I G 6 >rr0r!r1r*s@rr3r3G >>rr3c0^\rSrSrSrSU4SjjrSrU=r$)ValueDeserializationErrorZz Wraps all errors encountered during the deserialization of a Kafka Message's value. Args: exception(Exception, optional): The original exception kafka_message (Message, optional): The Kafka Message returned by the broker. cl>[[U] [[R[ U55XS9 gr6)r r=r r_VALUE_DESERIALIZATIONr8r9s rr "ValueDeserializationError.__init__gs/ '7 z88#i. I 8 >rr0r!r1r*s@rr=r=Zr;rr=c0^\rSrSrSrSU4SjjrSrU=r$) ProduceErrormz Wraps all errors encountered when Producing messages. Args: kafka_error (KafkaError): KafkaError instance. exception(Exception, optional): The original exception. c.>[[U] XS5 gr )r rCr )rrr rs rr ProduceError.__init__ws lD*;4Hrr0r r1r*s@rrCrCmsIIrrCc0^\rSrSrSrSU4SjjrSrU=r$)KeySerializationError{z Wraps all errors encountered during the serialization of a Message key. Args: exception (Exception): The exception that occurred during serialization. cl>[[U] [[R[ U55US9 gN)r )r rHr r_KEY_SERIALIZATIONr8rr rs rr KeySerializationError.__init__s/ #T3 z44c)n E 4 !rr0r r1r*s@rrHrH{!!rrHc0^\rSrSrSrSU4SjjrSrU=r$)ValueSerializationErrorz Wraps all errors encountered during the serialization of a Message value. Args: exception (Exception): The exception that occurred during serialization. cl>[[U] [[R[ U55US9 grK)r rQr r_VALUE_SERIALIZATIONr8rMs rr ValueSerializationError.__init__s/ %t5 z66I G 6 !rr0r r1r*s@rrQrQrOrrQN) confluent_kafka.cimplrrconfluent_kafka.serializationrrr,r3r=rCrHrQr0rrrXss$=<##6R$R,>l,>>&> .@>& I$ I !L*< ! !l,> !r