Ii.SSKJrJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK Jr SSKJr SSKJrJrJr SSKJr SSKJr SS KJr SS KJrJrJ r SS K!J"r" SS K#J$r$ SS K%J&r& SSK'J(r(J)r)J*r*J+r+ SSK J,r, SSK-J.r. \R^(aSr0\Rb"S5r2"SS\35r4SSKJ5r5 "SS\35r7"SS\35r8g!\ a SSK Jr Nf=f!\ a \6r5N3f=f))absolute_importdivisionN) selectors34)six)ClusterMetadata)BrokerConnectionConnectionStatesget_ip_port_afi)errors)Future)AnonMeasurable)AvgCountRate)TimeUnit)BROKER_API_VERSIONS)MetadataRequest)DictTimer WeakMethodensure_valid_topic_name) socketpair) __version__z kafka.clientcr\rSrSrSr0SS_S\"5_SS\-_SS _S S _S S _SS_SS _SS_SS_SS_S\R\RS4/_SS_SS_SS_SS_S S!_0S"S#_S$S_S%S_S&S_S'S_S(S_S)S_S*S_S+S_S,S_S-S._S/\ R_S0S_S1S2_S3S_S4S_S5S_ESS6SSSS7.Er S8r S9rS:rS;rS<rSbS=jrS>rS?rS@rSbSAjrSBrSCrScSDjrSErSFrSGrSHrSbSIjrSJrSdSKjr SeSLjr!SMr"SNr#ScSOjr$SPr%SQr&SRr'SSr(STr)SUr*SVr+SfSWjr,SXr-SeSYjr.ScSZjr/S[r0S\r1S]r2S^r3SgS_jr4S`r5Sar6g)h KafkaClient+a A network client for asynchronous request/response network I/O. This is an internal class used to implement the user-facing producer and consumer clients. This class is not thread-safe! Attributes: cluster (:any:`ClusterMetadata`): Local cache of cluster metadata, retrieved via MetadataRequests during :meth:`~kafka.KafkaClient.poll`. Keyword Arguments: bootstrap_servers: 'host[:port]' string (or list of 'host[:port]' strings) that the client should contact to bootstrap initial cluster metadata. This does not have to be the full node list. It just needs to have at least one broker that will respond to a Metadata API Request. Default port is 9092. If no servers are specified, will default to localhost:9092. client_id (str): a name for this client. This string is passed in each request to servers and can be used to identify specific server-side log entries that correspond to this client. Also submitted to GroupCoordinator for logging with respect to consumer group administration. Default: 'kafka-python-{version}' reconnect_backoff_ms (int): The amount of time in milliseconds to wait before attempting to reconnect to a given host. Default: 50. reconnect_backoff_max_ms (int): The maximum amount of time in milliseconds to backoff/wait when reconnecting to a broker that has repeatedly failed to connect. If provided, the backoff per host will increase exponentially for each consecutive connection failure, up to this maximum. Once the maximum is reached, reconnection attempts will continue periodically with this fixed rate. To avoid connection storms, a randomization factor of 0.2 will be applied to the backoff resulting in a random range between 20% below and 20% above the computed value. Default: 30000. request_timeout_ms (int): Client request timeout in milliseconds. Default: 30000. connections_max_idle_ms: Close idle connections after the number of milliseconds specified by this config. The broker closes idle connections after connections.max.idle.ms, so this avoids hitting unexpected socket disconnected errors on the client. Default: 540000 retry_backoff_ms (int): Milliseconds to backoff when retrying on errors. Default: 100. max_in_flight_requests_per_connection (int): Requests are pipelined to kafka brokers up to this number of maximum requests per broker connection. Default: 5. receive_buffer_bytes (int): The size of the TCP receive buffer (SO_RCVBUF) to use when reading data. Default: None (relies on system defaults). Java client defaults to 32768. send_buffer_bytes (int): The size of the TCP send buffer (SO_SNDBUF) to use when sending data. Default: None (relies on system defaults). Java client defaults to 131072. socket_options (list): List of tuple-arguments to socket.setsockopt to apply to broker connection sockets. Default: [(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)] metadata_max_age_ms (int): The period of time in milliseconds after which we force a refresh of metadata even if we haven't seen any partition leadership changes to proactively discover any new brokers or partitions. Default: 300000 allow_auto_create_topics (bool): Enable/disable auto topic creation on metadata request. Only available with api_version >= (0, 11). Default: True security_protocol (str): Protocol used to communicate with brokers. Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL. Default: PLAINTEXT. ssl_context (ssl.SSLContext): Pre-configured SSLContext for wrapping socket connections. If provided, all other ssl_* configurations will be ignored. Default: None. ssl_check_hostname (bool): Flag to configure whether SSL handshake should verify that the certificate matches the broker's hostname. Default: True. ssl_cafile (str): Optional filename of CA file to use in certificate verification. Default: None. ssl_certfile (str): Optional filename of file in PEM format containing the client certificate, as well as any CA certificates needed to establish the certificate's authenticity. Default: None. ssl_keyfile (str): Optional filename containing the client private key. Default: None. ssl_password (str): Optional password to be used when loading the certificate chain. Default: None. ssl_crlfile (str): Optional filename containing the CRL to check for certificate expiration. By default, no CRL check is done. When providing a file, only the leaf certificate will be checked against this CRL. The CRL can only be checked with Python 3.4+ or 2.7.9+. Default: None. ssl_ciphers (str): optionally set the available ciphers for ssl connections. It should be a string in the OpenSSL cipher list format. If no cipher can be selected (because compile-time options or other configuration forbids use of all the specified ciphers), an ssl.SSLError will be raised. See ssl.SSLContext.set_ciphers api_version (tuple): Specify which Kafka API version to use. If set to None, the client will attempt to determine the broker version via ApiVersionsRequest API or, for brokers earlier than 0.10, probing various known APIs. Dynamic version checking is performed eagerly during __init__ and can raise NoBrokersAvailableError if no connection was made before timeout (see api_version_auto_timeout_ms below). Different versions enable different functionality. Examples: (3, 9) most recent broker release, enable all supported features (0, 10, 0) enables sasl authentication (0, 8, 0) enables basic functionality only Default: None api_version_auto_timeout_ms (int): number of milliseconds to throw a timeout exception from the constructor when checking the broker api version. Only applies if api_version set to None. Default: 2000 selector (selectors.BaseSelector): Provide a specific selector implementation to use for I/O multiplexing. Default: selectors.DefaultSelector metrics (kafka.metrics.Metrics): Optionally provide a metrics instance for capturing network IO stats. Default: None. metric_group_prefix (str): Prefix for metric names. Default: '' sasl_mechanism (str): Authentication mechanism when security_protocol is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are: PLAIN, GSSAPI, OAUTHBEARER, SCRAM-SHA-256, SCRAM-SHA-512. sasl_plain_username (str): username for sasl PLAIN and SCRAM authentication. Required if sasl_mechanism is PLAIN or one of the SCRAM mechanisms. sasl_plain_password (str): password for sasl PLAIN and SCRAM authentication. Required if sasl_mechanism is PLAIN or one of the SCRAM mechanisms. sasl_kerberos_name (str or gssapi.Name): Constructed gssapi.Name for use with sasl mechanism handshake. If provided, sasl_kerberos_service_name and sasl_kerberos_domain name are ignored. Default: None. sasl_kerberos_service_name (str): Service name to include in GSSAPI sasl mechanism handshake. Default: 'kafka' sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI sasl mechanism handshake. Default: one of bootstrap servers sasl_oauth_token_provider (kafka.sasl.oauth.AbstractTokenProvider): OAuthBearer token provider instance. Default: None socks5_proxy (str): Socks5 proxy URL. Default: None bootstrap_servers localhostbootstrap_topics_filter client_idz kafka-python-request_timeout_ms0uwakeup_timeout_msi connections_max_idle_msi`=reconnect_backoff_ms2reconnect_backoff_max_ms%max_in_flight_requests_per_connectionreceive_buffer_bytesNsend_buffer_bytessocket_optionssock_chunk_bytesisock_chunk_buffer_countretry_backoff_msdallow_auto_create_topicsTmetadata_max_age_msisecurity_protocol PLAINTEXT ssl_contextssl_check_hostname ssl_cafile ssl_certfile ssl_keyfile ssl_password ssl_crlfile ssl_ciphers api_versionapi_version_auto_timeout_msiselectormetricsmetric_group_prefixsasl_mechanismsasl_plain_usernamesasl_plain_passwordkafka)sasl_kerberos_namesasl_kerberos_service_namesasl_kerberos_domain_namesasl_oauth_token_provider socks5_proxyc [R"UR5UlURHnX!;dM XURU'M SUlURS"5UlUR 5 [ R"5Ul[S 0URD6Ul [5Ul SUl [5UlSUl[5Ul[5UlSUlSUl[ R*"5Ul[.R0"5Ul[5URS5UlSUlURS(aJ[;URSURS[<R>"UR55UlURScURA5URS'gURS[B;a[BURSUlgURSS-[B;ao[DRGS URSURSS-5 URSS-URS'[BURSUlgSn[I[BRJ"5S S 9HnX@RS::dMUn O U(aA[DRGS URSU5 X0RS'[BUUlg[LRN"URS5e)NFrArr$rBrCr?)rz0Configured api_version %s is ambiguous; using %sT)reversez1Configured api_version %s not supported; using %s)(copyDEFAULT_CONFIGconfig_closed _selector_init_wakeup_socketpair threadingLock _wake_lockrclusterset_topics_metadata_refresh_in_progressr_conns _api_versions _connecting_sending_last_bootstrap_bootstrap_failsRLock_lock collectionsdeque_pending_completionIdleConnectionManager_idle_expiry_manager_sensorsKafkaClientMetricsweakrefproxy check_versionrlogwarningsortedkeysErrorsUnrecognizedBrokerVersion)selfconfigskeycompatible_versionvs 8/venv/lib/python3.13/site-packages/kafka/client_async.py__init__KafkaClient.__init__sii 3 34 ;;C~#*< C   Z02 $$&#..*&55 u -2*f !5  ! !__& $/#4#4#6 $9$++F_:`$a! ;;y !.t{{9/E/3{{;P/Q/6}}T[[/IKDM ;;} % -)-););)=DKK & [[ '+> >!4T[[5O!PD kk-(4/4G G KKJ M2DKK 4NQU4U W)-])Cd)JDKK &!4T[[5O!PD !% /446E M22)*&F" O KK 68JL-? M*%89K%L"66t{{=7QRRcJ[R"5uUlUlURR S5 URR UR SS- 5 SUlURRUR[R5 g)NFr#@@) socketr_wake_r_wake_w setblocking settimeoutrS_wakingrUregister selectors EVENT_READrvs r{rV#KafkaClient._init_wakeup_socketpairsq%+%6%6%8" dl   '  ,? @6 IJ   i.B.BCr~c>URb@URRUR5 URR 5 URbURR 5 SUlSUlg![[[ 4a Ngf=fN)rrU unregisterKeyError ValueError TypeErrorcloserrs r{_close_wakeup_socketpair$KafkaClient._close_wakeup_socketpair#s| << # ))$,,7 LL   << # LL     j)4  s%BBBcXR;a"URRU5(aggURUnUR5=(a UR 5(+$)NTF)r^rZbroker_metadata disconnected blacked_outrvnode_idconns r{ _can_connectKafkaClient._can_connect/sU ++ %||++G44{{7#  "=4+;+;+='==r~c, UR UR[RLaXR;aURR U5 UR RU[RU5 URRU5(a[R"5UlGOUR[R La.UR RU[RU5 GOoUR[R"[R$4;a.UR RU[R&U5 GOUR[R(LGaz[*R-SU5 XR;aURR/U5 UR RU[R&U5 UR0(a$UR0R2R55 UR6R9U5 URRU5(a'SUlUR<cUR<UlGO[?UR@RC55HNnURRU5(dM%UR@REU5RG5 MP GO{UR[RHLGa]XR;aURR/U5 UR RKU5 UR0(a$UR0RNR55 SnUR6RQU5(aSnUR6R/U5 XR@;aOURRU5(aU=R:S- slO]URS5(aHURT(d7U(d0[*RWSU5 URRY5 SSS5 g![a/ UR RU[RU5 GN7f=f![a. UR RU[RU5 N|f=f![a. UR RU[R&U5 Nf=f![a/ UR RU[R&U5 GN|f=f![[L4a GN!f=f!,(df  g=f)NzNode %s connectedrFTr-z0Node %s connection failed -- refreshing metadata)-restater CONNECTINGr`addrUrr EVENT_WRITErmodifyrZ is_bootstraptimerbAPI_VERSIONS_SENDAPI_VERSIONS_RECVAUTHENTICATINGr CONNECTEDrpdebugremoverkconnection_createdrecordrjupdatercr_listr^rspopr DISCONNECTEDrrconnection_closed is_expiredconnect_failedrTrqrequest_update)rvrsockridle_disconnects r{_conn_state_changeKafkaClient._conn_state_change7s ZZzz-888"2"22$$((1MNN++D)2G2GN<<,,W55+/99;D(/AAAMNN++D)2G2GN 0 B BDTDcDcddLNN++D)2F2FM/999 -w7...$$++G4NNN))$ 0D0DdK==MM44;;=))009<<,,W55,-D)))1-1-?-?*$( (8(8(:#;<<44W== KKOOG4::<$< /<<<...$$++G4NN--d3==MM33::<"',,77@@&*O))009++-\\..w77))Q.)((**4<<KK RT[\LL//1[Z MNN))$ 0E0EtLM MNN))$ 0E0EtLM  LNN))$ 0D0DdKL NNN++D)2F2FMN0!*-qZsAV+RAV+R<0V7+S7"A V+T2.CV A7VU. DV5R95V8R99V<5S41V3S44V75T/,V.T//V25U+'V*U++V.V>VVV VcURU5(a3URRU5 U(aUR5 gg)zAQueues a node for asynchronous connection during the next .poll()TF)rr`rwakeup)rvrrs r{ maybe_connectKafkaClient.maybe_connects;   W % %     ) r~c\XR;agURUR5$NF)r^rrvrs r{connection_failedKafkaClient.connection_faileds' ++ %{{7#2244r~cUR5(dgURRUR5nUcg[ UR 5un nUR U:wdUR UR :waM[RSURUR UR UR UR 5 gg)NFz?Broker metadata change detected for node %s from %s:%s to %s:%sT) rrZrrr hostportrpinfo)rvrbrokerr_s r{_should_recycle_connection&KafkaClient._should_recycle_connections  ""--dll; >$V[[1 a 99  V[[ 8 HH,-1\\499dii[[&++ /r~cUR URRU5nUbAURU5(a+URR U5R 5 SnUcUR RU5nUc [RSU5 SSS5 g[RSXRUR5 [UR5upEn[UR5n[XCRU4UUS.UR D6nX RU'UR#5(aUR%5 UR#5(+sSSS5 $!,(df  g=f)zIdempotent non-blocking connection attempt to the given node id. Returns True if connection object exists and is connected / connecting Nz$Broker id %s not in current metadataFz)Initiating connection to node %s at %s:%s)state_change_callbackr)rer^getrrrrZrrprrrr rrrrSrconnect)rvrrrrraficbs r{ _init_connectKafkaClient._init_connects4 ZZ;;??7+DD$C$CD$I$I (..0|55g>>IIDgN Z E!;; ="1&++">C 7 78'kk37>@077+/++7(, G$  "" ((**5ZZsBE;.CE;; F cBURU5 URXS9$)a,Check whether a node is connected and ok to send more requests. Arguments: node_id (int): the id of the node to check metadata_priority (bool): Mark node as not-ready if a metadata refresh is required. Default: True Returns: bool: True if we are ready to send to the given node )metadata_priority)ris_readyrvrrs r{readyKafkaClient.readys# 7#}}W}JJr~c`URRU5nUcgUR5$)z)Return True iff the node_id is connected.F)r^r connectedrs r{rKafkaClient.connecteds){{w' <~~r~cUR(d2SUlUR5 URR5 gg)NT)rTrrUrrs r{_closeKafkaClient._closes1||DL  ) ) + NN "r~cUR UcgUR5 [URR 55nURR 5 UHnUR 5 M OYXR;a*URRU5R 5 O [RSU5 SSS5 gSSS5 g!,(df  g=f)zjClose one or all broker connections. Arguments: node_id (int, optional): the id of the node to close Nz6Node %s not found in current connection list; skipping) rerrr^valuesclearrrrprq)rvrconnsrs r{rKafkaClient.closes ZZ T[[//12 !!#!DJJL"KK' (..0 TV]^ZZZs B;C C(c$UR5 gr)rrs r{__del__KafkaClient.__del__s  r~c`URRU5nUcgUR5$)aCheck whether the node connection has been disconnected or failed. A disconnected node has either been closed or has failed. Connection failures are usually transient and can be resumed in the next ready() call, but there are cases where transient failures need to be caught and re-acted upon. Arguments: node_id (int): the id of the node to check Returns: bool: True iff the node exists and is disconnected F)r^rrrs r{is_disconnectedKafkaClient.is_disconnecteds-{{w' <  ""r~c`URRU5nUcgUR5$)ax Return the number of milliseconds to wait, based on the connection state, before attempting to send data. When connecting or disconnected, this respects the reconnect backoff time. When connected, returns a very large number to handle slow/stalled connections. Arguments: node_id (int): The id of the node to check Returns: int: The number of milliseconds to wait. r)r^rconnection_delayrs r{rKafkaClient.connection_delays-{{w' <$$&&r~c`URRU5nUcgUR5$)z} Return the number of milliseconds to wait until a broker is no longer throttled. When disconnected / connecting, returns 0. r)r^rthrottle_delayrs r{rKafkaClient.throttle_delay"s- {{w' <""$$r~cURU5(dgU(a1UR(agURR5S:Xagg)aCheck whether a node is ready to send more requests. In addition to connection-level checks, this method also is used to block additional requests from being sent during a metadata refresh. Arguments: node_id (int): id of the node to check metadata_priority (bool): Mark node as not-ready if a metadata refresh is required. Default: True Returns: bool: True if the node is ready and metadata is not refreshing FrT)_can_send_requestr]rZttlrs r{rKafkaClient.is_ready,sD%%g.. 11||!Q&r~cURRU5nU(dgUR5=(a UR5$r)r^rr can_send_morers r{rKafkaClient._can_send_requestFs5{{w'~~8D$6$6$88r~cURRU5nU(aURU5(d<URXS9 [ 5R [ R"U55$URUSUS9nUR(dURRU5 U(aUR5 U$)aSend a request to a specific node. Bytes are placed on an internal per-connection send-queue. Actual network I/O will be triggered in a subsequent call to .poll() Arguments: node_id (int): destination node request (Struct): request object (not-encoded) Keyword Arguments: wakeup (bool, optional): optional flag to disable thread-wakeup. request_timeout_ms (int, optional): Provide custom timeout in milliseconds. If response is not processed before timeout, client will fail the request and close the connection. Default: None (uses value from client configuration) Raises: AssertionError: if node_id is not in current cluster metadata Returns: Future: resolves to Response struct or Error rF)blockingr!) r^rrrr failurertNodeNotReadyErrorsendis_donerarr)rvrrequestrr!rfutures r{rKafkaClient.sendLs,{{w'411'::   w  68##F$<$Timeouts: user %f, metadata %f, idle connection %f, request %fr0) isinstanceintfloattyperrrerTrr`rr_maybe_refresh_metadatar timeout_msrSrj next_check_ms_next_ifr_request_timeout_msrprminmax_pollextend _fire_pending_completed_requestsexpired) rvrrtimer responsesrmetadata_timeout_mstimeoutuser_timeout_msidle_connection_timeout_msr!s r{pollKafkaClient.pollvs *sE4:&>??:T*=MMN Nj! <<^U $D$4$45G --g66#&6&66 ,,33G< 6'+&B&B&D#%&..G:D:Pe&6&6VZVaVabvVwO151J1J1X1X1Z.)-)J)J)L&II^`oGav!'+2* ,G "!WoG 7T>*AH   TBBD E~  'EMMasG#4,G#$ G#5CG## G1cUR(aURR5nURcM:URR UR5nUR [ R-nURRURX2R5 UR(aMgg![a8 URRUR[ RU5 NVf=fr) rar_sockrUget_keyeventsrrrfileobjdatarr)rvrrxrs r{_register_send_sockets"KafkaClient._register_send_socketssmm==$$&Dzz! Qnn,,TZZ8i&;&;;%%ckk688Dmmm Q'' I4I4I4P QsA2C?DDcUS:aSn[5nUR5 [R"5nURR U5n[R"5nUR (a*UR R RXS- S-5 UGHupgURURLaUR5 M1U[R-(aURnUR5(aUR5 OUR!5(aUR"[R- (aMURR%URUR"[R- UR5 O%URR'UR5 U[R(-(dGM?URnUR+U5 UR,(daURR/S5n U (a[0R3SU5 UR9[:R<"S55 GMUR>RAURB5 URDRGUR/55 GM URHSS;aURJRM5HknX;dM URO5(dM!URPRS5(dMBURDRGUR/55 Mm [TRV"URJ5HznURY5(dMUR[5n U SS U SS- S -n [0R3S X5 UR9[:R\"S U -5S 9 M| UR (a>UR R^R[R"5U- S-5 URa5 g![4R6a GN,f=f)Ni iʚ;r-z#Protocol out of sync on %r, closingz,Socket EVENT_READ without in-flight-requestsr5)SSLSASL_SSLrr0z-%s timed out after %s ms. Closing connection.zRequest timed out after %s ms)error)1r[rrrUselectrk select_timerrr_clear_wake_fdrrr connectingrsend_pending_requests_v2rrrrrin_flight_requestsrecvrprqrr$rrtKafkaConnectionErrorrjrrrhr rSr^rrrpendingr itervaluesrequests_timed_outtimed_out_ifrsRequestTimedOutErrorio_time_maybe_close_oldest_connection) rvr processed start_selectr end_selectrxrrunexpected_data timed_outrs r{r KafkaClient._polls7 W GE  ##%yy{ %%g.YY[ == MM % % , ,j.G:-U V KC{{dll*##% ---xx??$$LLN4466:: (=(== NN11 # # Y-B-B B #* !NN55ckkBY11188D MM$ **&)kk&6&6q&9O& $I4P 6667efg  % % , ,T\\ :  $ $ + +DIIK 8a!f ;;* +/B B **,(T^^-=-=$**BTBTBVBV,,33DIIK@-NN4;;/D&&(( //1 'l1o ! Q?4G  K . !@$>DD334$>@A A@s"Bc/nURR5up#URU5 UR U5 MA![a U$f=fr)rhpopleft IndexErrorsuccessappend)rvrresponsers r{r,KafkaClient._fire_pending_completed_requests8se  $(#;#;#C#C#E  NN8 $   X &    sA AAcJURR5Vs/sHoRPM nn[R"U5 [ S5nSnUHnUR RU5nUSL=(a' UR5=(a UR5nUSL=(a' UR5=(d UR5nUb[UR5OSn U(a U S:XaUs $U(aMX:dMU nUnM U$s snf)aChoose the node with fewest outstanding requests, with fallbacks. This method will prefer a node with an existing connection (not throttled) with no in-flight-requests. If no such node is found, a node will be chosen randomly from all nodes that are not throttled or "blacked out" (i.e., are not subject to a reconnect backoff). If no node metadata has been obtained, will return a bootstrap node. Returns: node_id or None if no suitable node was found infNr)rZbrokersnodeIdrandomshufflerr^rrrr throttledr;r*) rvrnodesinflightfoundrrrr curr_inflights r{least_loaded_nodeKafkaClient.least_loaded_nodeGs.2\\-A-A-CD-C6-CDu<G;;??7+DD(VT^^-=V$BTBTBVId*W0@0@0B0VdnnFVK<@STlgr)r]) val_or_errorrvs r{ refresh_done9KafkaClient._maybe_refresh_metadata..refresh_dones 5:2r~)rZrr]rSr rQrWrprrr`rrrrrrrr\rr?rneed_all_topic_metadata ALL_TOPICS NO_TOPICSr add_callbackupdate_metadata add_errback failed_update) rvrrwait_for_in_progress_msmetadata_timeoutrnext_connect_msr[r?rrrks ` r{r#KafkaClient._maybe_refresh_metadatas ll GKGiGi$++.B"Cops< a # # ((* ?"??AO IIln} ~" "%%g..U|#""7++ SU\]  $$W-))'22$"2"22((//8;;'=>> 3**73Xt{{CW7XX  ! !' * *$,,'Fdll77@@dkk*CDE**?*JK||33(5@@(5??a)+6vt{{Ke?fg)+6v> II> QYYwY?F    < < =   t||99 :15D . ;    -   | ,;;34 4   < ;;56 6r~cUR$)zReturn the ApiVersions map, if available. Note: Only available after bootstrap; requires broker version 0.10.0 or later. Returns: a map of dict mapping {api_key : (min_version, max_version)}, or None if ApiVersion is not supported by the kafka cluster. )r_rs r{get_api_versionsKafkaClient.get_api_versionss!!!r~c zU=(d URSS- nUR [R"5U-n[R"5U:Ga#[U[R"5- S5nUbPUR U5S:a;[ XPR U5S- 5nUS:a[R "U5 MU=(d UR5nUcP[ XPR5S- 5nUS:a,[RSU5 [R "U5 M[RSU5 URU5(d!Xq:Xa[R"SU-5eGMHURUnUR!5(a}[R"5U:ad[ U[R"5- S-S 5n UR#U S 9 UR!5(a[R"5U:aMdUR$bUR$sSSS5 $[RS U5 [R"5U:aGM#Ub[R"U5e[R&"5e!,(df  g=f) apAttempt to guess the version of a Kafka broker. Keyword Arguments: node_id (str, optional): Broker node id from cluster metadata. If None, attempts to connect to any available broker until version is identified. Default: None timeout (num, optional): Maximum time in seconds to try to check broker version. If unable to identify version before timeout, raise error (see below). Default: api_version_auto_timeout_ms / 1000 Returns: version tuple, i.e. (3, 9), (2, 0), (0, 10, 2) etc Raises: NodeNotReadyError (if node_id is provided) NoBrokersAvailable (if node_id is None) r@r0rNrz:No node available during check_version; sleeping %.2f secsz(Attempting to check version with node %szConnection failed to %srz=Failed to identify api_version after connection attempt to %s)rSrerr rr sleeprQrWrprqrrrtrr^r(r _api_versionNoBrokersAvailable) rvrrkwargsendtime_remaining sleep_timetry_noderrs r{roKafkaClient.check_versions"Pdkk*GH4O ZZ))+'C))+#!$S499;%6!:&4+@+@+IA+M!$^5J5J75SV\5\!]J!A~ :.">d&<&<&>#!$^6W6W6Y\b6b!cJ!A~ $`blm :. DhO))(33*$667PSZ7Z[[ {{8,oo''DIIK#,=!$cDIIK&74%?!EJIII4oo''DIIK#,=$$0,,;Z>II]_cd;))+#B& 227;; 3355MZsHJ,*J, /J,>.J,, J:c[[U5S- UbUO [S55nURnUSRnUbXC;a2[ R "SRUSR55eX4upV[X&5nXu:a2[ R "SRUSR55eU$)a^Find the latest version of the protocol operation supported by both this library and the broker. This resolves to the lesser of either the latest api version this library supports, or the max version supported by the broker. Arguments: operation: A list of protocol operation versions from kafka.protocol. Keyword Arguments: max_version (int, optional): Provide an alternate maximum api version to reflect limitations in user code. Returns: int: The highest api version number compatible between client and broker. Raises: IncompatibleBrokerVersion if no matching version is found r-rGrz6Kafka broker does not support the '{}' Kafka protocol.zQNo version of the '{}' Kafka protocol is supported by both the client and broker.) r r;rr_API_KEYrtIncompatibleBrokerVersionformat__name__)rv operationrgbroker_api_versionsapi_keybroker_min_versionbroker_max_versionversions r{r?KafkaClient.api_version4s(#i.1,[=TkZ_`eZfg "00A,&&  &'*L22H ! --.0 02E1M.k6  '22c ! --.0 0r~cUR(dUR(d URcgUR URR S5 SUlSSS5 g![ R a0n[RS5 [R"U5eSnAf[ Ran[RSU5 UeSnAff=f!,(df  g=f)NxTz!Timeout to send to wakeup socket!z#Unable to send to wakeup socket! %s) rTrrrYsendallrrrprqrtKafkaTimeoutErrorr$)rves r{rKafkaClient.wakeupYs <<4<<4<<+?  __  $$T*# _>> 2 ?@..q11<<  A1E _s4C!"A++C?+B**CCCC!! C/cJUR SUlURRS5(d6[R S5 UR 5 UR5 OMZSSS5 g![Ra M f=f!,(df  g=f)NFiz3Error reading wakeup socket. Rebuilding socketpair.) rYrrr+rprqrrVrr$rs r{r'KafkaClient._clear_wake_fdgs __ DL <<,,T22 $YZ557446 3_||_s/ BAA9,B9B BBB B"cURR5nU(aEUup#[R"5U- S-n[R SX$5 UR US9 gg)Nr0z1Closing idle connection %s, last active %d ms ago)r)rjpoll_expired_connectionrrprr)rvexpired_connectionconn_idtsidle_mss r{r3*KafkaClient._maybe_close_oldest_connectionwsX!66NNP ,KGyy{R'4/G HHH' [ JJwJ ' r~cURHInURRU5(dM%URUR5(dMI g g)z,Return True if a bootstrap node is connectedTF)r^rZrrrs r{bootstrap_connectedKafkaClient.bootstrap_connectedsH{{G<<,,W55{{7#--// # r~c[U5nURSS9 URU5(agURU5(dUR(dUR U5(a[ R "SU<S35eURU5 URURS9 URU5(dUR(dMURU5$)a Invokes `poll` to discard pending disconnects, followed by `client.ready` and 0 or more `client.poll` invocations until the connection to `node` is ready, the timeoutMs expires or the connection fails. It returns `true` if the call completes normally or `false` if the timeoutMs expires. If the connection fails, an `IOException` is thrown instead. Note that if the `NetworkClient` has been configured with a positive connection timeoutMs, it is possible for this method to raise an `IOException` for a previous connection which has recently disconnected. This method is useful for implementing blocking behaviour on top of the non-blocking `NetworkClient`, use it with care. rr}TzConnection to z failed.) rrrrrrtr,rr)rvrrrs r{ await_readyKafkaClient.await_readysj! Q  == ! !--((%%g..11PW2YZZ   w ' II!1!1I 2 --(( }}W%%r~cURX5nURUS9 UR(deUR5(a UReUR $)N)r)rrrfailed exceptionvalue)rvrrrs r{send_and_receiveKafkaClient.send_and_receivesK7,   ~~~ ==??"" "||r~)r_rcrTr`r^rjrbrer]rhrUrarkr\rYrrrrZrS)Tr)TN)NN)F)r")7r __module__ __qualname____firstlineno____doc__r[rr IPPROTO_TCP TCP_NODELAYrDefaultSelectorrRr|rVrrrrrrrrrrrrrrrrrrrrr r=rrQrTrWr\r`r rryror?rr'r3rrr__static_attributes__rPr~r{rr+sEN([(!35( _{2( e ( T ( "= ( ( #E( 0( ( T( F..0B0BAFG( D( "4( C( #D!(" v#($ [%(& t'(( d)(* d+(, -(. t/(0 1(2 t3(4 t5(6 t7(8 &t9(: I--;(< 4=(> r?(@ $A(B tC(D tE(F#&-%)%)O(NT=S~D >N2` 5 &+B K # &#&'$%49 (TFP QY.vA& B2 a -* H7T"86t#J  (&2r~r) OrderedDictc>\rSrSrSrSrSrSrSrSr Sr S r g ) riicUS:a US- UlO[S5UlSUlUR[R"55 [ 5Ulg)Nrr0rG)connections_max_idlernext_idle_close_check_time!update_next_idle_close_check_timerrlru_connections)rvr$s r{r|IdleConnectionManager.__init__sI "Q &(?$(FD %(-e D %*.' ..tyy{;*}r~cXR;a URU [R"5URU'gr)rrrvrs r{rIdleConnectionManager.updates2 ** *$$W-(, W%r~c>XR;aURU ggr)rrs r{rIdleConnectionManager.removes! ** *$$W- +r~cXR;ag[R"5URUUR-:$r)rrrrs r{r IdleConnectionManager.is_expireds8 .. .yy{d227;d>W>WWWWr~c[R"5nUR(aUR[S5:Xa [S5$URU::ag[ URU- S-5$)NrGrr0)rrrrr)rvnows r{r#IdleConnectionManager.next_check_mss^iik##t'F'F%PU,'V<   , , 377#=EF Fr~c*XR-Ulgr)rr)rvrs r{r7IdleConnectionManager.update_next_idle_close_check_times*,/H/H*H'r~c[R"5UR:ag[UR5(dgSnSn[[ La2URR 5Hup4UbXB:dMUnUnM O.[[URR 555upURU5 [R"5X R-:aX4$gr) rrr;rrdictitemsnextiterrr)rvoldest_conn_id oldest_tsrrs r{r-IdleConnectionManager.poll_expired_connections 99;88 84''(( $ #3399; !)R^%,N "I < +/tD4H4H4N4N4P/Q*R '^ ..y9 99;)&?&?? ?". .r~)rrrN) rrrrr|rrrrrrrrPr~r{riris(-4 .X GIr~ric\rSrSrSrSrg)rlic^XlUS-UlURS5UlURR UR SURS5[ 55 URS5UlURR UR SURS5[ 55 URS5UlURR UR S URS 5[ [5S 95 URR UR S URS 5[55 URR UR SURS5[ [RS95 URS5Ul URR UR SURS5[55 URR UR SURS5[ [RS95 URUR SURS5[U4Sj55 g)Nz-metricszconnections-closedzconnection-close-ratez,Connections closed per second in the window.zconnections-createdzconnection-creation-ratez5New connections established per second in the window.z select-timez select-ratezGNumber of times the I/O layer checked for new I/O to perform per second) sampled_statzio-wait-time-ns-avgznThe average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds.z io-wait-ratioz2The fraction of time the I/O thread spent waiting.) time_unitzio-timezio-time-ns-avgzBThe average length of time for I/O per select call in nanoseconds.zio-ratioz3The fraction of time the I/O thread spent doing I/Ozconnection-countz)The current number of active connections.c>[T5$r)r;)rSrrs r{-KafkaClientMetrics.__init__..s CJr~)rBmetric_group_namesensorrr metric_namerrr&rrr NANOSECONDSr2 add_metricr )rvrBrCrs `r{r|KafkaClientMetrics.__init__s4 !4z!A!(0D!E ""7#6#6 #T%;%; :$<=AV E#*..1F"G ##G$7$7 &(>(> C%EFJf N#>>-8 W00 411 %'2 4 W00 !4#9#9 @ACF% I W00 T33 @B 8// 0 2 ~~i0  ,, d44 PR E  ,, .. AC 8// 0 2 7..  6 6 79:H.;0 1r~)rrr2rrBr&N)rrrrr|rrPr~r{rlrls(1r~rl)9 __future__rrrfrQloggingrJrrWrrmr ImportError kafka.vendorrr kafka.clusterr kafka.connrr r rHr rt kafka.futurer kafka.metricsr kafka.metrics.statsrrrkafka.metrics.stats.rater"kafka.protocol.broker_api_versionsrkafka.protocol.metadatar kafka.utilrrrrr kafka.versionrPY2ConnectionError getLoggerrpobjectrrrrirlrPr~r{rs0   6 )JJ"(00-B3GG$%77O'}&}B$' ;F;|)1)1E'656~$Ks#C;C* C'&C'*C54C5