o `šjþ-ã @s ddlZddlmZmZddlmZmZmZmZm Z m Z m Z m Z e  dddg¡ZGdd „d eƒZGd d „d eƒZGd d „d eƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGd d!„d!eƒZGd"d#„d#eƒZGd$d%„d%eƒZGd&d'„d'eƒZGd(d)„d)eƒZGd*d+„d+eƒZ Gd,d-„d-eƒZ!Gd.d/„d/eƒZ"Gd0d1„d1eƒZ#Gd2d3„d3eƒZ$Gd4d5„d5eƒZ%Gd6d7„d7eƒZ&eeeeee e!e"e#e$e%e&g Z'eeeeeeeeeeeeg Z(dS)8éNé)ÚRequestÚResponse)ÚArrayÚInt8ÚInt16ÚInt32ÚInt64ÚSchemaÚStringÚBytesÚAbortedTransactionÚ producer_idÚ first_offsetc @sTeZdZdZdZedededƒfdedefde fd e fd e fƒfƒfƒZ d diZ d S) ÚFetchResponse_v0rrÚ responsesÚtopicúutf-8Ú partitionsÚpartition_indexÚ error_codeÚhigh_watermarkÚrecordsÚtopicsN)Ú__name__Ú __module__Ú __qualname__ÚAPI_KEYÚ API_VERSIONr rr rrr r ÚSCHEMAÚALIASES©r!r!úV/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/fetch.pyr s  üþÿ ÿrc @sXeZdZdZdZedefdededƒfdedefde fd e fd e fƒfƒfƒZ e jZd S) ÚFetchResponse_v1rÚthrottle_time_msrrrrrrrrN)rrrrrr rrr rr r rrr r!r!r!r"r#s  üþþ r#c@ó eZdZdZdZejZejZdS)ÚFetchResponse_v2réN)rrrrrr#rr r!r!r!r"r&,ó  r&c@r%)ÚFetchResponse_v3réN)rrrrrr&rr r!r!r!r"r)3r(r)c@sreZdZdZdZedefdededƒfdedefd e fd e fd e fd ed e fde fƒfde fƒfƒfƒZ e jZdS)ÚFetchResponse_v4rér$rrrrrrrÚlast_stable_offsetÚaborted_transactionsrrrN)rrrrrr rrr rr r rr)r r!r!r!r"r+:s* þøþþ r+c@sxeZdZdZdZedefdededƒfdedefd e fd e fd e fd e fd ede fde fƒfde fƒfƒfƒZ e jZdS)ÚFetchResponse_v5rér$rrrrrrrr-Úlog_start_offsetr.rrrN)rrrrrr rrr rr r rr+r r!r!r!r"r/Os, þ÷þþ r/c@ó$eZdZdZdZdZejZejZdS)ÚFetchResponse_v6zò Same as FetchResponse_v5. The version number is bumped up to indicate that the client supports KafkaStorageException. The KafkaStorageException will be translated to NotLeaderForPartitionException in the response if version <= 5 réN) rrrÚ__doc__rrr/rr r!r!r!r"r3ds  r3c@sˆeZdZdZdZdZedefdefdefde de d ƒfd e d efdefd e fd e fde fde de fde fƒfde fƒfƒfƒZ ejZdS)ÚFetchResponse_v7z3 Add error_code and session_id to response rér$rÚ session_idrrrrrrr-r1r.rrrN)rrrr5rrr rrrr r r rr3r r!r!r!r"r6os2 þ÷þü r6c@r%)ÚFetchResponse_v8réN)rrrrrr6rr r!r!r!r"r9‰r(r9c@r%)ÚFetchResponse_v9ré N)rrrrrr9rr r!r!r!r"r;r(r;c@r%)ÚFetchResponse_v10ré N)rrrrrr;rr r!r!r!r"r=—r(r=c@sŠeZdZdZdZedefdefdefdede dƒfd ed efdefd e fd e fd e fdede fde fƒfdefde fƒfƒfƒZ e jZdS)ÚFetchResponse_v11ré r$rr8rrrrrrr-r1r.rrÚpreferred_read_replicarN)rrrrrr rrrr r r rr=r r!r!r!r"r?žs2 þöþü r?c @s`eZdZdZdZedefdefdefdededƒfd ed efd e fd efƒfƒfƒZ d diZ dS)ÚFetchRequest_v0rrÚ replica_idÚ max_wait_msÚ min_bytesrrrrÚ partitionÚ fetch_offsetÚpartition_max_bytesÚ max_wait_timeN) rrrrrr rrr r rr r!r!r!r"rB¶s$ ýþü ÿrBc@s eZdZdZdZejZejZdS)ÚFetchRequest_v1rN)rrrrrrBrr r!r!r!r"rJÉr(rJc@r%)ÚFetchRequest_v2rr'N)rrrrrrJrr r!r!r!r"rKÐr(rKc@sdeZdZdZdZedefdefdefdefdeded ƒfd ed efd e fd efƒfƒfƒZ e j Z dS)ÚFetchRequest_v3rr*rCrDrEÚ max_bytesrrrrrFrGrHN) rrrrrr rrr r rrKr r!r!r!r"rL×s$ ýþû rLc@sjeZdZdZdZedefdefdefdefdefded e d ƒfd ed efd e fdefƒfƒfƒZ e j Z dS)ÚFetchRequest_v4rr,rCrDrErMÚisolation_levelrrrrrFrGrHN)rrrrrr rrrr r rrLr r!r!r!r"rNés& ýþú rNc@speZdZdZdZedefdefdefdefdefded e d ƒfd ed efd e fde fdefƒfƒfƒZ e j Z dS)ÚFetchRequest_v5rr0rCrDrErMrOrrrrrFrGr1rHN)rrrrrr rrrr r rrNr r!r!r!r"rPþs( üþú rPc@r2)ÚFetchRequest_v6a The body of FETCH_REQUEST_V6 is the same as FETCH_REQUEST_V5. The version number is bumped up to indicate that the client supports KafkaStorageException. The KafkaStorageException will be translated to NotLeaderForPartitionException in the response if version <= 5 rr4N) rrrr5rrrPrr r!r!r!r"rQs  rQc@sœeZdZdZdZdZedefdefdefdefdefd efd efd e d e d ƒfde defde fde fdefƒfƒfde d e d ƒfde eƒfƒfƒ Z e jZdS)ÚFetchRequest_v7z6 Add incremental fetch requests (see KIP-227) rr7rCrDrErMrOr8Ú session_epochrrrrrFrGr1rHÚforgotten_topics_dataN)rrrr5rrr rrrr r rrQr r!r!r!r"rRs6 üþ  þñ rRc@r2)ÚFetchRequest_v8ze bump used to indicate that on quota violation brokers send out responses before throttling. rr:N) rrrr5rrrRrr r!r!r!r"rU<ó  rUc@s¢eZdZdZdZdZedefdefdefdefdefd efd efd e d e d ƒfde defdefde fde fdefƒfƒfde d e d ƒfde eƒfƒfƒ Z e jZdS)ÚFetchRequest_v9z5 adds the current leader epoch (see KIP-320) rr<rCrDrErMrOr8rSrrrrrFÚcurrent_leader_epochrGr1rHrTN)rrrr5rrr rrrr r rrUr r!r!r!r"rWFs8 ûþ  þð rWc@r2)ÚFetchRequest_v10zC bumped up to indicate ZStandard capability. (see KIP-110) rr>N) rrrr5rrrWrr r!r!r!r"rYdrVrYc@s¬eZdZdZdZdZedefdefdefdefdefd efd efd e d e d ƒfde defdefde fde fdefƒfƒfde d e d ƒfde eƒfƒfde d ƒfƒ Z e jZdS)ÚFetchRequest_v11z@ added rack ID to support read from followers (KIP-392) rr@rCrDrErMrOr8rSrrrrrFrXrGr1rHrTÚrack_idN)rrrr5rrr rrrr r rrYr r!r!r!r"rZns: ûþ  þ ì rZ))Ú collectionsÚapirrÚtypesrrrrr r r r Ú namedtupler rr#r&r)r+r/r3r6r9r;r=r?rBrJrKrLrNrPrQrRrUrWrYrZÚ FetchRequestÚ FetchResponser!r!r!r"ÚsP(ÿ     üü