Ii  SSKJr SSKrSSKr"SS\5r"SS\5r"SS\5r"S S \5r"S S \5r "S S\5r "SS\5r "SS\5r "SS\5r "SS\ 5r"SS\5r"SS\5r"SS\5r"SS\5r"SS \5r"S!S"\5r"S#S$\5r"S%S&\5r"S'S(\5r"S)S*\5r"S+S,\5r"S-S.\5r"S/S0\5r"S1S2\5r"S3S4\5r"S5S6\5r\r"S7S8\5r "S9S:\5r!"S;S<\5r""S=S>\5r#"S?S@\5r$"SASB\5r%"SCSD\5r&"SESF\5r'"SGSH\5r("SISJ\5r)"SKSL\5r*"SMSN\5r+"SOSP\5r,"SQSR\5r-"SSST\5r."SUSV\5r/"SWSX\5r0"SYSZ\5r1"S[S\\5r2"S]S^\5r3"S_S`\5r4"SaSb\5r5"ScSd\5r6"SeSf\5r7"SgSh\5r8"SiSj\5r9"SkSl\5r:"SmSn\5r;"SoSp\5r<"SqSr\5r="SsSt\5r>"SuSv\5r?"SwSx\5r@"SySz\5rA"S{S|\5rB"S}S~\5rC"SS\5rD"SS\5rE"SS\5rF"SS\5rG"SS\5rH"SS\5rI"SS\5rJ"SS\5rK"SS\5rL"SS\5rM"SS\5rN"SS\5rO"SS\5rP"SS\5rQ"SS\5rR"SS\5rS"SS\5rT"SS\5rU"SS\5rV"SS\5rW"SS\5rX"SS\5rY"SS\5rZ"SS\5r["SS\5r\"SS\5r]"SS\5r^"SS\5r_"SS\5r`"SS\5ra"SS\5rb"SS\5rc"SS\5rd"SS\5re"SS\5rf"SS\5rg"SS\5rh"SS\5ri"SS\5rj"SS\5rk"SS\5rl"SS\5rm"SS\5rn"SS\5ro"SS\5rp"SS\5rq"SS\5rr"SS\5rs"SS\5rt"SS\5ru"SS\5rv"SS\5rw"SS\5rx"SS\5ry"SS\5rz"SS\5r{"SS\5r|"SS\5r}"SS\5r~"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GS GS \5r"GS GS \5r"GS GS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS\5r"GSGS \5r"GS!GS"\5r"GS#GS$\5r"GS%GS&\5r"GS'GS(\5r"GS)GS*\5r"GS+GS,\5r"GS-GS.\5r"GS/GS0\5rGS1r\"\"5Vs/sHoGR>U4PM sn5rGS2rgs snf(3)absolute_importNc0^\rSrSrSrSrU4SjrSrU=r$) KafkaErrorFc>UR(dURR$SRURR[[ U]55$)Nz{0}: {1})args __class____name__formatsuperr__str__selfr s 2/venv/lib/python3.13/site-packages/kafka/errors.pyr KafkaError.__str__ sHyy>>** *  !8!8$Z>@B B) r __module__ __qualname____firstlineno__ retriableinvalid_metadatar __static_attributes__ __classcell__r s@rrrsIBBrrc\rSrSrSrSrg) CancelledTrNr rrrrrrrrrrIrrc(^\rSrSrU4SjrSrU=r$)CommitFailedErrorc:>U(dSn[[U] "U6 g)N)zpCommit cannot be completed since the group has already rebalanced and assigned the partitions to another member.)r r"__init__)rrr s rr%CommitFailedError.__init__sSD /6rr)r rrrr%rrrs@rr"r"s 77rr"c\rSrSrSrg)IllegalArgumentErrorrNr rrrrrrrr(r(rr(c\rSrSrSrg)IllegalStateError#rNr*rrrr-r-#r+rr-c\rSrSrSrg)IncompatibleBrokerVersion'rNr*rrrr0r0'r+rr0c\rSrSrSrg)KafkaConfigurationError+rNr*rrrr3r3+r+rr3c\rSrSrSrSrSrg)KafkaConnectionError/TrNr rrrrrrrrrr6r6/ Irr6c\rSrSrSrSrg)KafkaProtocolError4TrNrrrrr;r;4r rr;c\rSrSrSrSrg)CorrelationIdError8TrNrrrrr>r>8r rr>c\rSrSrSrSrg)KafkaTimeoutError<TrNrrrrrArA<r rrAc\rSrSrSrSrg)MetadataEmptyBrokerList@TrNrrrrrDrD@r rrDc\rSrSrSrSrSrg)NoBrokersAvailableDTrNr8rrrrGrGDr9rrGc\rSrSrSrg)NoOffsetForPartitionErrorIrNr*rrrrJrJIr+rrJc\rSrSrSrSrg)NodeNotReadyErrorMTrNrrrrrMrMMr rrMc\rSrSrSrg)QuotaViolationErrorQrNr*rrrrPrPQr+rrPc\rSrSrSrSrSrg) StaleMetadataUTrNr8rrrrSrSUr9rrSc\rSrSrSrSrg)TooManyInFlightRequestsZTrNrrrrrVrVZr rrVc\rSrSrSrg)UnrecognizedBrokerVersion^rNr*rrrrYrY^r+rrYc\rSrSrSrg)UnsupportedCodecErrorbrNr*rrrr\r\br+rr\c4^\rSrSrSrSrSrU4SjrSrU=r $)BrokerResponseErrorfNc\>SRUR[[U]55$)z$Add errno to standard KafkaError strz[Error {0}] {1})r errnor r_r rs rr BrokerResponseError.__str__ks+ '' JJ %t 4 68 8rr) r rrrrbmessage descriptionr rrrs@rr_r_fs EGK88rr_c\rSrSrSrg)AuthorizationErrorrrNr*rrrrgrgrr+rrgc \rSrSrSrSrSrSrg)NoErrorvrNO_ERRORzNo error--it worked!rNr rrrrbrdrerrrrrjrjvs EG(Krrjc \rSrSrSrSrSrSrg) UnknownError|UNKNOWNzAn unexpected server error.rNrmrrrroro|s EG/Krroc \rSrSrSrSrSrSrg)OffsetOutOfRangeErrorOFFSET_OUT_OF_RANGEzlThe requested offset is outside the range of offsets maintained by the server for the given topic/partition.rNrmrrrrtrts E#GNKrrtc \rSrSrSrSrSrSrg)CorruptRecordErrorCORRUPT_MESSAGEzZThis message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt.rNrmrrrryrys EG;Krryc(\rSrSrSrSrSrSrSrSr g)UnknownTopicOrPartitionErrorUNKNOWN_TOPIC_OR_PARTITIONzLThis request is for a topic or partition that does not exist on this broker.TrN r rrrrbrdrerrrrrrr~r~s E*G,KIrr~c \rSrSrSrSrSrSrg)InvalidFetchRequestErrorINVALID_FETCH_SIZEz The message has a negative size.rNrmrrrrrs E"G4Krrc(\rSrSrSrSrSrSrSrSr g)LeaderNotAvailableErrorLEADER_NOT_AVAILABLEzThis error is thrown if we are in the middle of a leadership election and there is currently no leader for this partition and hence it is unavailable for writes.TrNrrrrrrs! E$GMKIrrc(\rSrSrSrSrSrSrSrSr g)NotLeaderForPartitionErrorNOT_LEADER_FOR_PARTITIONzThis error is thrown if the client attempts to send messages to a replica that is not the leader for some partition. It indicates that the clients metadata is out of date.TrNrrrrrrs E(GKIrrc$\rSrSrSrSrSrSrSrg)RequestTimedOutErrorrREQUEST_TIMED_OUTzYThis error is thrown if the request exceeds the user-specified time limit in the request.TrN r rrrrbrdrerrrrrrrs E!G@KIrrc \rSrSrSrSrSrSrg)BrokerNotAvailableErrorBROKER_NOT_AVAILABLEzYThis is not a client facing error and is used mostly by tools when a broker is not alive.rNrmrrrrrs E$G8Krrc(\rSrSrSrSrSrSrSrSr g)ReplicaNotAvailableError REPLICA_NOT_AVAILABLEzLIf replica is expected on a broker, but is not (this can be safely ignored).TrNrrrrrrs E%G'KIrrc \rSrSrSrSrSrSrg)MessageSizeTooLargeError MESSAGE_SIZE_TOO_LARGEzThe server has a configurable maximum message size to avoid unbounded memory allocation. This error is thrown if the client attempt to produce a message larger than this maximum.rNrmrrrrrs E&GKrrc \rSrSrSrSrSrSrg)StaleControllerEpochError STALE_CONTROLLER_EPOCHz7Internal error code for broker-to-broker communication.rNrmrrrrrs E&GKKrrc \rSrSrSrSrSrSrg)OffsetMetadataTooLargeError OFFSET_METADATA_TOO_LARGEzKIf you specify a string larger than configured maximum for offset metadata.rNrmrrrrrs E)G'Krrc$\rSrSrSrSrSrSrSrg)NetworkExceptionError NETWORK_EXCEPTIONTrN) r rrrrbrdrrrrrrrrs E!GIrrc$\rSrSrSrSrSrSrSrg)CoordinatorLoadInProgressErrorCOORDINATOR_LOAD_IN_PROGRESSz}The broker returns this error code for txn or group requests, when the coordinator is loading and hence cant process requestsTrNrrrrrrs E,GVKIrrc$\rSrSrSrSrSrSrSrg)CoordinatorNotAvailableErrorCOORDINATOR_NOT_AVAILABLEzThe broker returns this error code for consumer and transaction requests if the offsets topic has not yet been created, or if the group/txn coordinator is not active.TrNrrrrrrs E)GBKIrrc$\rSrSrSrSrSrSrSrg)NotCoordinatorErrorNOT_COORDINATORzwThe broker returns this error code if it is not the correct coordinator for the specified consumer or transaction groupTrNrrrrrrs EGRKIrrc \rSrSrSrSrSrSrg)InvalidTopicErrori INVALID_TOPICzFor a request which attempts to access an invalid topic (e.g. one which has an illegal name), or if an attempt is made to write to an internal topic (such as the consumer offsets topic).rNrmrrrrrs EG/Krrc \rSrSrSrSrSrSrg)RecordListTooLargeErrori RECORD_LIST_TOO_LARGEzTIf a message batch in a produce request exceeds the maximum configured segment size.rNrmrrrrr s E%G/Krrc$\rSrSrSrSrSrSrSrg)NotEnoughReplicasErrorirNOT_ENOUGH_REPLICASzReturned from a produce request when the number of in-sync replicas is lower than the configured minimum and requiredAcks is -1.TrNrrrrrrs E#G*KIrrc$\rSrSrSrSrSrSrSrg)!NotEnoughReplicasAfterAppendErrori NOT_ENOUGH_REPLICAS_AFTER_APPENDzwReturned from a produce request when the message was written to the log, but with fewer in-sync replicas than required.TrNrrrrrrs E0G KIrrc \rSrSrSrSrSrSrg)InvalidRequiredAcksErrori&INVALID_REQUIRED_ACKSzkReturned from a produce request if the requested requiredAcks is invalid (anything other than -1, 1, or 0).rNrmrrrrr&s E%GQKrrc \rSrSrSrSrSrSrg)IllegalGenerationErrori-ILLEGAL_GENERATIONzReturned from group membership requests (such as heartbeats) when the generation id provided in the request is not the current generation.rNrmrrrrr-s E"G*Krrc \rSrSrSrSrSrSrg)InconsistentGroupProtocolErrori5r#INCONSISTENT_GROUP_PROTOCOLzReturned in join group when the member provides a protocol type or set of protocols which is not compatible with the current group.rNrmrrrrr5s E+G%Krrc \rSrSrSrSrSrSrg)InvalidGroupIdErrori=INVALID_GROUP_IDz9Returned in join group when the groupId is empty or null.rNrmrrrrr=s E GMKrrc \rSrSrSrSrSrSrg)UnknownMemberIdErroriCUNKNOWN_MEMBER_IDzzReturned from group requests (offset commits/fetches, heartbeats, etc) when the memberId is not in the current generation.rNrmrrrrrCs E!G"Krrc \rSrSrSrSrSrSrg)InvalidSessionTimeoutErroriKINVALID_SESSION_TIMEOUTzeReturn in join group when the requested session timeout is outside of the allowed range on the brokerrNrmrrrrrKs E'GAKrrc \rSrSrSrSrSrSrg)RebalanceInProgressErroriRREBALANCE_IN_PROGRESSzReturned in heartbeat requests when the coordinator has begun rebalancing the group. This indicates to the client that it should rejoin the group.rNrmrrrrrRs E%G7Krrc \rSrSrSrSrSrSrg)InvalidCommitOffsetSizeErroriZINVALID_COMMIT_OFFSET_SIZEzUThis error indicates that an offset commit was rejected because of oversize metadata.rNrmrrrrrZs E*G4Krrc \rSrSrSrSrSrSrg)TopicAuthorizationFailedErroriaTOPIC_AUTHORIZATION_FAILEDzWReturned by the broker when the client is not authorized to access the requested topic.rNrmrrrrras E*G2Krrc \rSrSrSrSrSrSrg)GroupAuthorizationFailedErrorihGROUP_AUTHORIZATION_FAILEDzXReturned by the broker when the client is not authorized to access a particular groupId.rNrmrrrrrhs E*G3Krrc \rSrSrSrSrSrSrg)ClusterAuthorizationFailedErrorior)CLUSTER_AUTHORIZATION_FAILEDzfReturned by the broker when the client is not authorized to use an inter-broker or administrative API.rNrmrrrrros E,GAKrrc \rSrSrSrSrSrSrg)InvalidTimestampErroriv INVALID_TIMESTAMPz8The timestamp of the message is out of acceptable range.rNrmrrrrrvs E!GLKrrc \rSrSrSrSrSrSrg)UnsupportedSaslMechanismErrori|!UNSUPPORTED_SASL_MECHANISMz9The broker does not support the requested SASL mechanism.rNrmrrrrr|s E*GMKrrc \rSrSrSrSrSrSrg)IllegalSaslStateErrori"ILLEGAL_SASL_STATEz2Request is not valid given the current SASL state.rNrmrrrrrs E"GFKrrc \rSrSrSrSrSrSrg)UnsupportedVersionErrorir.UNSUPPORTED_VERSIONz$The version of API is not supported.rNrmrrrr r s E#G8Krr c \rSrSrSrSrSrSrg)TopicAlreadyExistsErrori$TOPIC_ALREADY_EXISTSz$Topic with this name already exists.rNrmrrrr r s E$G8Krr c \rSrSrSrSrSrSrg)InvalidPartitionsErrori%INVALID_PARTITIONSz Number of partitions is invalid.rNrmrrrrrs E"G4Krrc \rSrSrSrSrSrSrg)InvalidReplicationFactorErrori&INVALID_REPLICATION_FACTORzReplication-factor is invalid.rNrmrrrrrs E*G2Krrc \rSrSrSrSrSrSrg)!InvalidReplicationAssignmentErrorir1INVALID_REPLICATION_ASSIGNMENTz"Replication assignment is invalid.rNrmrrrrrs E.G6Krrc \rSrSrSrSrSrSrg)InvalidConfigurationErrori(INVALID_CONFIGzConfiguration is invalid.rNrmrrrrrs EG-Krrc$\rSrSrSrSrSrSrSrg)NotControllerErrori)NOT_CONTROLLERz4This is not the correct controller for this cluster.TrNrrrrr r s EGHKIrr c \rSrSrSrSrSrSrg)InvalidRequestErrori*INVALID_REQUESTzThis most likely occurs because of a request being malformed by the client library or the message was sent to an incompatible broker. See the broker logs for more details.rNrmrrrr$r$s EG(Krr$c \rSrSrSrSrSrSrg) UnsupportedForMessageFormatErrorir4UNSUPPORTED_FOR_MESSAGE_FORMATzGThe message format version on the broker does not support this request.rNrmrrrr(r(s E.G,Krr(c$\rSrSrSrSrSrSrSrg)PolicyViolationErrori,POLICY_VIOLATIONz8Request parameters do not satisfy the configured policy.FrNrrrrr+r+s E GLKIrr+c$\rSrSrSrSrSrSrSrg)OutOfOrderSequenceNumberErrori-OUT_OF_ORDER_SEQUENCE_NUMBERz4The broker received an out of order sequence number.FrNrrrrr/r/s E,GHKIrr/c$\rSrSrSrSrSrSrSrg)DuplicateSequenceNumberErrori.DUPLICATE_SEQUENCE_NUMBERz0The broker received a duplicate sequence number.FrNrrrrr3r3s E)GDKIrr3c$\rSrSrSrSrSrSrSrg)InvalidProducerEpochErrorir7INVALID_PRODUCER_EPOCHz0Producer attempted to produce with an old epoch.FrNrrrrr7r7s E&GDKIrr7c$\rSrSrSrSrSrSrSrg)InvalidTxnStateErrori0INVALID_TXN_STATEzEThe producer attempted a transactional operation in an invalid state.FrNrrrrr:r:s E!GYKIrr:c$\rSrSrSrSrSrSrSrg)InvalidProducerIdMappingErrori1INVALID_PRODUCER_ID_MAPPINGzdThe producer attempted to use a producer id which is not currently assigned to its transactional id.FrNrrrrr>r>s E+GxKIrr>c$\rSrSrSrSrSrSrSrg)InvalidTransactionTimeoutErrori2INVALID_TRANSACTION_TIMEOUTz}The transaction timeout is larger than the maximum value allowed by the broker (as configured by transaction.max.timeout.ms).FrNrrrrrBrBs E+GRKIrrBc$\rSrSrSrSrSrSrSrg)ConcurrentTransactionsErrori3CONCURRENT_TRANSACTIONSzvThe producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing.TrNrrrrrFrFs E'GKKIrrFc$\rSrSrSrSrSrSrSrg)!TransactionCoordinatorFencedErrorir<TRANSACTION_COORDINATOR_FENCEDz~Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer.FrNrrrrrJrJs E.GSKIrrJc$\rSrSrSrSrSrSrSrg)'TransactionalIdAuthorizationFailedErrori5%TRANSACTIONAL_ID_AUTHORIZATION_FAILEDz&Transactional Id authorization failed.FrNrrrrrMrM E5G:KIrrMc$\rSrSrSrSrSrSrSrg)SecurityDisabledErrori 6SECURITY_DISABLEDzSecurity features are disabled.FrNrrrrrRrR s E!G3KIrrRc$\rSrSrSrSrSrSrSrg)OperationNotAttemptedErrori7OPERATION_NOT_ATTEMPTEDzThe broker did not attempt to execute this operation. This may happen for batched RPCs where some operations in the batch failed, causing the broker to respond without trying the rest.FrNrrrrrVrVs E'GMKIrrVc(\rSrSrSrSrSrSrSrSr g)KafkaStorageErrorir?KAFKA_STORAGE_ERRORz6Disk error when trying to access log file on the disk.TrNrrrrrZrZs E#GJKIrrZc$\rSrSrSrSrSrSrSrg)LogDirNotFoundErrori9LOG_DIR_NOT_FOUNDzCThe user-specified log directory is not found in the broker config.FrNrrrrr]r]s E!GWKIrr]c$\rSrSrSrSrSrSrSrg)SaslAuthenticationFailedErrori&:SASL_AUTHENTICATION_FAILEDzSASL Authentication failed.FrNrrrrrara&s E*G/KIrrac$\rSrSrSrSrSrSrSrg)UnknownProducerIdErrori-;UNKNOWN_PRODUCER_IDaThis exception is raised by the broker if it could not locate the producer metadata associated with the producerId in question. This could happen if, for instance, the producer's records were deleted because their retention time had elapsed. Once the last records of the producerId are removed, the producer's metadata is removed from the broker, and future appends by the producer will return this exception.FrNrrrrrere-s E#GpKIrrec$\rSrSrSrSrSrSrSrg)ReassignmentInProgressErrori4rBREASSIGNMENT_IN_PROGRESSz(A partition reassignment is in progress.FrNrrrrriri4s E(GDELEGATION_TOKEN_NOT_FOUNDz(Delegation Token is not found on server.FrNrrrrrprpBs E*G  ??3  Js4G$H$HSTgMgI?sA A<A<'A<3 A<cPU[;a [U$[S[4SU05$)NUnrecognizedBrokerErrorrb) kafka_errorstypero) error_codes rfor_codery!s.\!J''- *@UVVr) __future__rrkrm RuntimeErrorrrr"r(r-r0r3r6r;r>rArDrGrJrMrPrSrVrYr\r_rgrjrortryCorruptRecordExceptionr~rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrr r$r(r+r/r3r7r:r>rBrFrJrMrRrVrZr]rarerirlrprtrxr{rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrr"r&r*r.r2r6r9r=rArErHrLrPrTrXr\r_rcrgrsdictrbrvry)xs0rrs&  B B 7 7 :      j : + j     * J j   J  8* 8 , )!) 0&0 O/O<,<,#6525 1!4.9192 2 L 3L ("5(/%8#6-0+00100(;R2R+0+&%8&N-N #.#B!4B8285#653$634$64B&8BM/M N$7N G/G 919 919 505 3$73 7(;7 . 3. ,)-)-':-.$7#6 3.$7%8"5(;.@/!4+-$70"5':#6(;,?.@"5 3,."5$7/!401&9/1/':2/':0$7"5, 3#6-/0"5 3 32+>/1-':!42!4#620/&90 32/"5#62!402 31 3$7/.-, +>+@A+@aggq\+@AB  WBs[2