9h/d SSKJr SSKJrJr /SQr"SS\5r"SS\5r"SS \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.S/\5r"S0S1\5r"S2S3\5r"S4S5\5r "S6S7\5r!"S8S9\5r""S:S;\5r#"S<S=\5r$"S>S?\$5r%"S@SA\$5r&"SBSC\$5r'"SDSE\$5r(\(r)"SFSG\$5r*"SHSI\$5r+"SJSK\$5r,"SLSM\$5r-"SNSO\$5r."SPSQ\$5r/"SRSS\$5r0"STSU\$5r1"SVSW\$5r2"SXSY\$5r3"SZS[\$5r4"S\S]\$5r5\5r6"S^S_\$5r7\7r8"S`Sa\$5r9\9r:"SbSc\$5r;"SdSe\$5r<"SfSg\$5r="ShSi\$5r>"SjSk\$5r?"SlSm\$5r@"SnSo\$5rA"SpSq\$5rB"SrSs\$5rC"StSu\$5rD"SvSw\$5rE"SxSy\$5rF"SzS{\$5rG"S|S}\$5rH"S~S\$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\"S\tS9ruS\uS\\u4Sjrv\v"\$5Vs0sHoRU_M snrxS\yS\t\$4Sjrzgs snf))Iterable)AnyTypeVar)FConsumerStoppedErrorNoOffsetForPartitionErrorRecordTooLargeErrorProducerClosed KafkaErrorIllegalStateErrorIllegalArgumentErrorNoBrokersAvailableNodeNotReadyErrorKafkaProtocolErrorCorrelationIdError CancelledTooManyInFlightRequests StaleMetadataUnrecognizedBrokerVersionIncompatibleBrokerVersionCommitFailedError AuthenticationMethodNotSupportedAuthenticationFailedErrorBrokerResponseErrorNoError UnknownErrorOffsetOutOfRangeErrorCorruptRecordExceptionUnknownTopicOrPartitionErrorInvalidFetchRequestErrorLeaderNotAvailableErrorNotLeaderForPartitionErrorRequestTimedOutErrorBrokerNotAvailableErrorReplicaNotAvailableErrorMessageSizeTooLargeErrorStaleControllerEpochErrorOffsetMetadataTooLargeErrorStaleLeaderEpochCodeErrorGroupLoadInProgressError!GroupCoordinatorNotAvailableErrorNotCoordinatorForGroupErrorInvalidTopicErrorRecordListTooLargeErrorNotEnoughReplicasError!NotEnoughReplicasAfterAppendErrorInvalidRequiredAcksErrorIllegalGenerationErrorInconsistentGroupProtocolErrorInvalidGroupIdErrorUnknownMemberIdErrorInvalidSessionTimeoutErrorRebalanceInProgressErrorInvalidCommitOffsetSizeErrorTopicAuthorizationFailedErrorGroupAuthorizationFailedErrorClusterAuthorizationFailedErrorInvalidTimestampErrorUnsupportedSaslMechanismErrorIllegalSaslStateErrorUnsupportedVersionErrorTopicAlreadyExistsErrorInvalidPartitionsErrorInvalidReplicationFactorError!InvalidReplicationAssignmentErrorInvalidConfigurationErrorNotControllerErrorInvalidRequestError UnsupportedForMessageFormatErrorPolicyViolationErrorKafkaUnavailableErrorKafkaTimeoutErrorKafkaConnectionErrorUnsupportedCodecErrorc8^\rSrSrSrSrS\4U4SjjrSrU=r $)r QFreturnc>UR(dURR$URRS[TU]53$)Nz: )args __class____name__super__str__selfrQs TC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/errors.pyrTKafkaError.__str__Vs>yy>>** *..))*"UW_->,?@@) rR __module__ __qualname____firstlineno__ retriableinvalid_metadatastrrT__static_attributes__ __classcell__rQs@rWr r Qs"IAAArYr c\rSrSrSrg)r \rZNrRr[r\r]rarZrYrWr r \rYr c\rSrSrSrg)r `rZNrfrZrYrWr r `rgrYr c\rSrSrSrSrSrg)r dTrZNrRr[r\r]r^r_rarZrYrWr r d IrYr c\rSrSrSrSrg)riTrZNrRr[r\r]r^rarZrYrWrriIrYrc\rSrSrSrSrg)rmTrZNrprZrYrWrrmrqrYrc\rSrSrSrSrg)rqTrZNrprZrYrWrrqrqrYrc\rSrSrSrSrg)ruTrZNrprZrYrWrrurqrYrc\rSrSrSrSrg)ryTrZNrprZrYrWrryrqrYrc\rSrSrSrSrSrg)r}TrZNrlrZrYrWrr}rmrYrc\rSrSrSrSrg)MetadataEmptyBrokerListTrZNrprZrYrWr}r}rqrYr}c\rSrSrSrg)rrZNrfrZrYrWrrrgrYrc\rSrSrSrg)rrZNrfrZrYrWrrrgrYrc8^\rSrSrS\S\SS4U4SjjrSrU=r$)rrPkwargsrNNc.>[TU]"S/UQ70UD6 g)NaWCommit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max_poll_interval_ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the rebalance timeout with max_poll_interval_ms, or by reducing the maximum size of batches returned in poll() with max_poll_records. rS__init__)rVrPrrQs rWrCommitFailedError.__init__s)     rYrZ)rRr[r\r]rrrarbrcs@rWrrs" c S T  rYrc\rSrSrSrg)rrZNrfrZrYrWrrrgrYrc\rSrSrSrSrg)rFrZNrprZrYrWrrsIrYrc\rSrSrSrg)rHrZNrfrZrYrWrHrHrgrYrHc\rSrSrSrg)rIrZNrfrZrYrWrIrIrgrYrIc\rSrSrSrSrSrg)rJTrZNrlrZrYrWrJrJrmrYrJc\rSrSrSrg)rKrZNrfrZrYrWrKrKrgrYrKc\rSrSrSrg)KafkaConfigurationErrorrZNrfrZrYrWrrrgrYrc\rSrSrSrg)QuotaViolationErrorrZNrfrZrYrWrrrgrYrc\rSrSrSrSrg)rzKRaised on `get*` methods of Consumer if it's cancelled, even pending ones. rZNrRr[r\r]__doc__rarZrYrWrrsrYrc\rSrSrSrSrg)IllegalOperationzRaised if you try to execute an operation, that is not available with current configuration. For example trying to commit if no group_id was given. rZNrrZrYrWrrsrYrc\rSrSrSrg)rrZNrfrZrYrWrrrgrYrc\rSrSrSrg)rrZNrfrZrYrWrrrgrYrc\rSrSrSrg)r rZNrfrZrYrWr r rgrYr c>^\rSrSrSrSS\SS4U4SjjjrSrU=r$) ProducerFencedzAnother producer with the same transactional ID went online. NOTE: As it seems this will be raised by Broker if transaction timeout occurred also. msgrNNc$>[TU]U5 gNr)rVrrQs rWrProducerFenced.__init__s rYrZ)zThere is a newer producer using the same transactional_id ortransaction timeout occurred (check that processing time is below transaction_timeout_ms)) rRr[r\r]rr`rrarbrcs@rWrrs) ,  rYrcT^\rSrSr%\\S'\\S'Sr\\S'S\4U4SjjrSr U=r $) rerrnomessage descriptionrNc@>SURS[TU] 53$)z$Add errno to standard KafkaError strz[Error z] )rrSrTrUs rWrTBrokerResponseError.__str__s" Buw'8&9::rYrZ) rRr[r\r]int__annotations__r`rrTrarbrcs@rWrrs( J LK;;;rYrc \rSrSrSrSrSrSrg)rrNO_ERRORzNo error--it worked!rZNrRr[r\r]rrrrarZrYrWrrs EG(KrYrc \rSrSrSrSrSrSrg)rUNKNOWNzAn unexpected server error.rZNrrZrYrWrrs EG/KrYrc \rSrSrSrSrSrSrg)riOFFSET_OUT_OF_RANGEzlThe requested offset is outside the range of offsets maintained by the server for the given topic/partition.rZNrrZrYrWrrs E#G CrYrc \rSrSrSrSrSrSrg)ri CORRUPT_MESSAGEzZThis message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt.rZNrrZrYrWrr s EG 0rYrc(\rSrSrSrSrSrSrSrSr g)riUNKNOWN_TOPIC_OR_PARTITIONzLThis request is for a topic or partition that does not exist on this broker.TrZN rRr[r\r]rrrr^r_rarZrYrWrrs# E*G !IrYrc \rSrSrSrSrSrSrg)ri"INVALID_FETCH_SIZEz The message has a negative size.rZNrrZrYrWrr"s E"G4KrYrc(\rSrSrSrSrSrSrSrSr g)r i(LEADER_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.TrZNrrZrYrWr r (s$ E$G B IrYr c(\rSrSrSrSrSrSrSrSr g)r!i4NOT_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.TrZNrrZrYrWr!r!4s# E(G  IrYr!c$\rSrSrSrSrSrSrSrg)r"iAREQUEST_TIMED_OUTzYThis error is thrown if the request exceeds the user-specified time limit in the request.TrZN rRr[r\r]rrrr^rarZrYrWr"r"As E!G 5IrYr"c \rSrSrSrSrSrSrg)r#iKBROKER_NOT_AVAILABLEzYThis is not a client facing error and is used mostly by tools when a broker is not alive.rZNrrZrYrWr#r#Ks E$G -rYr#c \rSrSrSrSrSrSrg)r$iT REPLICA_NOT_AVAILABLEzLIf replica is expected on a broker, but is not (this can be safely ignored).rZNrrZrYrWr$r$Ts E%G rYr$c \rSrSrSrSrSrSrg)r%i] 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.rZNrrZrYrWr%r%]s E&G rYr%c \rSrSrSrSrSrSrg)r&ih STALE_CONTROLLER_EPOCHz7Internal error code for broker-to-broker communication.rZNrrZrYrWr&r&hs E&GKKrYr&c \rSrSrSrSrSrSrg)r'in OFFSET_METADATA_TOO_LARGEzKIf you specify a string larger than configured maximum for offset metadata.rZNrrZrYrWr'r'ns E)GUrYr'c\rSrSrSrSrSrg)r(ix STALE_LEADER_EPOCH_CODErZN)rRr[r\r]rrrarZrYrWr(r(xs E'GrYr(c$\rSrSrSrSrSrSrSrg)r)i}COORDINATOR_LOAD_IN_PROGRESSaThe broker returns this error code for an offset fetch request if it is still loading offsets (after a leader change for that offsets topic partition), or in response to group membership requests (such as heartbeats) when group metadata is being loaded by the coordinator.TrZNrrZrYrWr)r)}s E,G >IrYr)c$\rSrSrSrSrSrSrSrg)r*iCOORDINATOR_NOT_AVAILABLEzThe broker returns this error code for group coordinator requests, offset commits, and most group management requests if the offsets topic has not yet been created, or if the group coordinator is not active.TrZNrrZrYrWr*r*s E)G 3 IrYr*c$\rSrSrSrSrSrSrSrg)r+iNOT_COORDINATORzThe broker returns this error code if it receives an offset fetch or commit request for a group that it is not a coordinator for.TrZNrrZrYrWr+r+s EG  IrYr+c \rSrSrSrSrSrSrg)r,i 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).rZNrrZrYrWr,r,s EG $rYr,c \rSrSrSrSrSrSrg)r-iRECORD_LIST_TOO_LARGEzTIf a message batch in a produce request exceeds the maximum configured segment size.rZNrrZrYrWr-r-s E%G $rYr-c$\rSrSrSrSrSrSrSrg)r.iNOT_ENOUGH_REPLICASzReturned from a produce request when the number of in-sync replicas is lower than the configured minimum and requiredAcks is -1.TrZNrrZrYrWr.r.s E#G  IrYr.c$\rSrSrSrSrSrSrSrg)r/i 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.TrZNrrZrYrWr/r/s E0G  IrYr/c \rSrSrSrSrSrSrg)r0iINVALID_REQUIRED_ACKSzkReturned from a produce request if the requested requiredAcks is invalid (anything other than -1, 1, or 0).rZNrrZrYrWr0r0s E%G FrYr0c \rSrSrSrSrSrSrg)r1iILLEGAL_GENERATIONzReturned from group membership requests (such as heartbeats) when the generation id provided in the request is not the current generation.rZNrrZrYrWr1r1s E"G rYr1c \rSrSrSrSrSrSrg)r2iINCONSISTENT_GROUP_PROTOCOLzReturned in join group when the member provides a protocol type or set of protocols which is not compatible with the current group.rZNrrZrYrWr2r2s E+G rYr2c \rSrSrSrSrSrSrg)r3iINVALID_GROUP_IDz9Returned in join group when the groupId is empty or null.rZNrrZrYrWr3r3s E GMKrYr3c \rSrSrSrSrSrSrg)r4iUNKNOWN_MEMBER_IDzzReturned from group requests (offset commits/fetches, heartbeats, etc) when the memberId is not in the current generation.rZNrrZrYrWr4r4s E!G rYr4c \rSrSrSrSrSrSrg)r5iINVALID_SESSION_TIMEOUTzeReturn in join group when the requested session timeout is outside of the allowed range on the brokerrZNrrZrYrWr5r5s E'G 6rYr5c \rSrSrSrSrSrSrg)r6i REBALANCE_IN_PROGRESSzReturned in heartbeat requests when the coordinator has begun rebalancing the group. This indicates to the client that it should rejoin the group.rZNrrZrYrWr6r6 s E%G ,rYr6c \rSrSrSrSrSrSrg)r7iINVALID_COMMIT_OFFSET_SIZEzUThis error indicates that an offset commit was rejected because of oversize metadata.rZNrrZrYrWr7r7s E*G )rYr7c \rSrSrSrSrSrSrg)r8iTOPIC_AUTHORIZATION_FAILEDzWReturned by the broker when the client is not authorized to access the requested topic.rZNrrZrYrWr8r8s E*G 'rYr8c \rSrSrSrSrSrSrg)r9i&GROUP_AUTHORIZATION_FAILEDzXReturned by the broker when the client is not authorized to access a particular groupId.rZNrrZrYrWr9r9&s E*G (rYr9c \rSrSrSrSrSrSrg)r:i/CLUSTER_AUTHORIZATION_FAILEDzfReturned by the broker when the client is not authorized to use an inter-broker or administrative API.rZNrrZrYrWr:r:/s E,G 6rYr:c \rSrSrSrSrSrSrg)r;i8 INVALID_TIMESTAMPz8The timestamp of the message is out of acceptable range.rZNrrZrYrWr;r;8s E!GLKrYr;c \rSrSrSrSrSrSrg)r<i>!UNSUPPORTED_SASL_MECHANISMz9The broker does not support the requested SASL mechanism.rZNrrZrYrWr<r<>s E*GMKrYr<c \rSrSrSrSrSrSrg)r=iD"ILLEGAL_SASL_STATEz2Request is not valid given the current SASL state.rZNrrZrYrWr=r=Ds E"GFKrYr=c \rSrSrSrSrSrSrg)r>iJ#UNSUPPORTED_VERSIONz$The version of API is not supported.rZNrrZrYrWr>r>Js E#G8KrYr>c \rSrSrSrSrSrSrg)r?iP$TOPIC_ALREADY_EXISTSz$Topic with this name already exists.rZNrrZrYrWr?r?Ps E$G8KrYr?c \rSrSrSrSrSrSrg)r@iV%INVALID_PARTITIONSz Number of partitions is invalid.rZNrrZrYrWr@r@Vs E"G4KrYr@c \rSrSrSrSrSrSrg)rAi\&INVALID_REPLICATION_FACTORzReplication-factor is invalid.rZNrrZrYrWrArA\s E*G2KrYrAc \rSrSrSrSrSrSrg)rBib'INVALID_REPLICATION_ASSIGNMENTz"Replication assignment is invalid.rZNrrZrYrWrBrBbs E.G6KrYrBc \rSrSrSrSrSrSrg)rCih(INVALID_CONFIGzConfiguration is invalid.rZNrrZrYrWrCrChs EG-KrYrCc$\rSrSrSrSrSrSrSrg)rDin)NOT_CONTROLLERz4This is not the correct controller for this cluster.TrZNrrZrYrWrDrDns EGHKIrYrDc \rSrSrSrSrSrSrg)rEiu*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.rZNrrZrYrWrErEus EG rYrEc \rSrSrSrSrSrSrg)rFi+UNSUPPORTED_FOR_MESSAGE_FORMATzGThe message format version on the broker does not support this request.rZNrrZrYrWrFrFs E.GQrYrFc \rSrSrSrSrSrSrg)rGi,POLICY_VIOLATIONz8Request parameters do not satisfy the configured policy.rZNrrZrYrWrGrGs E GLKrYrGc \rSrSrSrSrSrSrg)OutOfOrderSequenceNumberi-OUT_OF_ORDER_SEQUENCE_NUMBERz3The broker received an out of order sequence numberrZNrrZrYrWrIrIs E,GGKrYrIc \rSrSrSrSrSrSrg)DuplicateSequenceNumberi.DUPLICATE_SEQUENCE_NUMBERz/The broker received a duplicate sequence numberrZNrrZrYrWrMrMs E)GCKrYrMc \rSrSrSrSrSrSrg)InvalidProducerEpochi/INVALID_PRODUCER_EPOCHzProducer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has been expired by the broker.rZNrrZrYrWrQrQs E&G ArYrQc \rSrSrSrSrSrSrg)InvalidTxnStatei0INVALID_TXN_STATEzDThe producer attempted a transactional operation in an invalid staterZNrrZrYrWrUrUs E!GXKrYrUc \rSrSrSrSrSrSrg)InvalidProducerIdMappingi1INVALID_PRODUCER_ID_MAPPINGzcThe producer attempted to use a producer id which is not currently assigned to its transactional idrZNrrZrYrWrYrYs E+G +rYrYc \rSrSrSrSrSrSrg)InvalidTransactionTimeouti2INVALID_TRANSACTION_TIMEOUTz}The transaction timeout is larger than the maximum value allowed by the broker (as configured by transaction.max.timeout.ms).rZNrrZrYrWr]r]s E+G ErYr]c \rSrSrSrSrSrSrg)ConcurrentTransactionsi3CONCURRENT_TRANSACTIONSzuThe producer attempted to update a transaction while another concurrent operation on the same transaction was ongoingrZNrrZrYrWraras E'G CrYrac \rSrSrSrSrSrSrg)TransactionCoordinatorFencedi4TRANSACTION_COORDINATOR_FENCEDz}Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producerrZNrrZrYrWreres E.G ErYrec \rSrSrSrSrSrSrg)"TransactionalIdAuthorizationFailedi5%TRANSACTIONAL_ID_AUTHORIZATION_FAILEDz%Transactional Id authorization failedrZNrrZrYrWriris E5G9KrYric \rSrSrSrSrSrSrg)SecurityDisabledi6SECURITY_DISABLEDzSecurity features are disabledrZNrrZrYrWrmrms E!G2KrYrmc \rSrSrSrSrSrSrg)OperationNotAttemptedi7OPERATION_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.rZNrrZrYrWrqrqs E'G 9rYrqc \rSrSrSrSrSrSrg)KafkaStorageErrori8KAFKA_STORAGE_ERRORCThe user-specified log directory is not found in the broker config.rZNrrZrYrWrurus E#GWKrYruc \rSrSrSrSrSrSrg)LogDirNotFoundi9LOG_DIR_NOT_FOUNDrxrZNrrZrYrWrzrzs E!GWKrYrzc \rSrSrSrSrSrSrg)SaslAuthenticationFailedi:SASL_AUTHENTICATION_FAILEDzSASL Authentication failed.rZNrrZrYrWr~r~s E*G/KrYr~c \rSrSrSrSrSrSrg)UnknownProducerIdi;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.rZNrrZrYrWrrs E#G rYrc \rSrSrSrSrSrSrg)ReassignmentInProgressi<REASSIGNMENT_IN_PROGRESSz'A partition reassignment is in progressrZNrrZrYrWrrs E(G;KrYrc \rSrSrSrSrSrSrg)DelegationTokenAuthDisabledi =DELEGATION_TOKEN_AUTH_DISABLEDz'Delegation Token feature is not enabledrZNrrZrYrWrr s E.G;KrYrc \rSrSrSrSrSrSrg)DelegationTokenNotFoundi>DELEGATION_TOKEN_NOT_FOUNDz(Delegation Token is not found on server.rZNrrZrYrWrrs E*Gr?r@rArBrCrDrErFrGrIrMrQrUrYr]rarerirmrqrurzr~rrrrrrrrrrrrrrrtyperrrrrr)xs0rWrs$J ZAA   :   + jJ j      $ z   J   :  J  j  * 9 y   *  Z Z";*;)!) 0&0 /0-#6525 1  !4 .122L 3L "5( 3( 2 ": (;  A"52+10(;20%8N-N .!42#6$7$7&9M/M N$7N G/G 919 919 505 3$73 7(;7 . 3. ,-':M.M H2H D1D .Y)Y 2 30#6:)<: 3*3 /X+X X(X 020 + <0< <"5< =1= D#6D ':;)<; 101 <.< +'+ 0)0 707 727 ** T.".". %55H$IJ$Iq $IJ 66&9!:6Ks0S