IiSSKJr SSKrSSKrSSKJr SSKJr SSK J r SSK J r J r SSKJr \R "\5r"SS\5rg) )absolute_importN)FindCoordinatorResponse) KafkaBytes)Int32 TaggedFields __version__cP\rSrSrSrS SjrSrSrSSjrSr S r S r S r S r g) KafkaProtocolaManage the kafka network protocol Use an instance of KafkaProtocol to manage bytes send/recv'd from a network socket to a broker. Arguments: client_id (str): identifier string to be included in each request api_version (tuple): Optional tuple to specify api_version to use. Currently only used to check for 0.8.2 protocol quirks, but may be used for more in the future. NcUcUR5nXlX lSUl[ S5UlSUlSUl[R"5Ul /Ul g)NrF) _gen_client_id _client_id _api_version_correlation_idr_header_rbuffer _receiving collectionsdequein_flight_requests bytes_to_send)self client_id api_versions ;/venv/lib/python3.13/site-packages/kafka/protocol/parser.py__init__KafkaProtocol.__init__s[  ++-I#' !!}  "-"3"3"5cHURS-S-UlUR$)Nl)rrs r_next_correlation_id"KafkaProtocol._next_correlation_id's& $ 4 4q 8EA###r cS[-$)Nz kafka-pythonrr#s rrKafkaProtocol._gen_client_id+s  ++r c[RSU5 UcUR5nURX RS9nSR UR 5UR 5/5n[R "[U55nXT-nURRU5 UR5(aX!4nURRU5 U$)a9Encode and queue a kafka api request for sending. Arguments: request (object): An un-encoded kafka request. correlation_id (int, optional): Optionally specify an ID to correlate requests with responses. If not provided, an ID will be generated automatically. Returns: correlation_id zSending request %s)correlation_idrr ) logdebugr$ build_headerrjoinencoderlenrappendexpect_responser)rrequestr)headermessagesizedataifrs r send_requestKafkaProtocol.send_request.s &0  !!668N%%^%_((FMMOW^^-=>?||CL)~ !!$'  " " $ $!+C  # # * *3 /r cJSRUR5n/UlU$)z1Retrieve all pending bytes to send on the networkr )r-r)rr6s r send_bytesKafkaProtocol.send_bytesHs#xx**+ r c`Sn[U5n/nX#:GaUR(d[SURR 5- X2- 5nURR XX%-5 X%- nURR 5S:XaSURR S5 [R"UR5n[U5Ul SUlO4URR 5S:a[R"S5eUR(a[UR5nURR 5n[Xx- X2- 5nURR XX%-5 X%- nURR 5nX:a[R"S5eX:waU$SUlURR S5 URUR5n URU 5 UR5 X#:aGMU$)aProcess bytes received from the network. Arguments: data (bytes): any length bytes received from a network connection to a kafka broker. Returns: responses (list of (correlation_id, response)): any/all completed responses, decoded from bytes to python objects. Raises: KafkaProtocolError: if the bytes received could not be decoded. CorrelationIdError: if the response does not match the request correlation id. rrTz+this should not happen - are you threading?z,Receive buffer has more bytes than expected?F)r/rminrtellwriteseekrdecoderrErrors KafkaError_process_responser0 _reset_buffer) rr6in responses bytes_to_readnbytes total_bytes staged_bytesresps r receive_bytesKafkaProtocol.receive_bytesNs  I e?? #A (9(9(;$;QU C  ""4!/#:;"<<$$&!+LL%%a("\\$,,7F$.v$6DM&*DO\\&&(1, ++,YZZ!$--0 #}}113 #K$> F  ##D1?$;<"#}}113 - ++,Z[[. #( ""1%--dmm<  &""$GeHr c UR(d[R"S5eURR5up#URnUR U5nUR n[RSU5 US:XaEUS:wa?U[SLa3URS:Xd URc[RS5 OX&:wa[R"SX&4-5e[RSUR5 URU5nX'4$![aZ URS5 UR!5n[R#SX$U[%U5U5 [R&"S 5ef=f) Nz.No in-flight-request found for server responsezReceived correlation id: %dr)rzKafka 0.8.2 quirk -- GroupCoordinatorResponse Correlation ID does not match request. This should go away once at least one topic has been initialized on the broker.z.Correlation IDs do not match: sent %d, recv %dzProcessing response %szOResponse %d [ResponseType: %s Request: %s]: Unable to decode %d-byte buffer: %rzUnable to decode response)rrCCorrelationIdErrorpopleft RESPONSE_TYPE parse_headerr)r*r+rrwarning__name__rB ValueErrorrAreaderrorr/KafkaProtocolError) r read_bufferr)r2 response_typeresponse_headerrecv_correlation_idresponsebufs rrEKafkaProtocol._process_responsesv&&++,\] ]$($;$;$C$C$E!-- '44[A-<< /1DE 1 $ a  4Q7 7   ) +t/@/@/H KK6 7  2++@!789 9 *M,B,BC I$++K8H)) I   Q ""$C II=$s3x .++,GH H Is D""A$FcVSUlURRS5 SUlg)NFr)rrrArr#s rrFKafkaProtocol._reset_buffers" ! r )rrrrrrrr)NN)N)rY __module__ __qualname____firstlineno____doc__rr$rr8r;rOrErF__static_attributes__r rr r s1   $,4 7r%*Nr r ) __future__rrlogging kafka.errorserrorsrCkafka.protocol.find_coordinatorrkafka.protocol.framerkafka.protocol.typesrr kafka.versionr getLoggerrYr*objectr rlr rrws;&C+4% !bFbr