
    Ii              	          S SK Jr  S SKJrJr  S SKJrJrJrJ	r	J
r
JrJr   " S S\5      r " S S\5      r " S S	\5      r " S
 S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S  S!\5      r " S" S#\5      r " S$ S%\5      r " S& S'\5      r " S( S)\5      r\\\\\\\\\/	r\\\\\\\\\/	r g*)+    )absolute_import)RequestResponse)Int16Int32Int64StringArraySchemaBytesc                   n    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S\
4S	\45      45      45      rS
rg)ProduceResponse_v0   r   topicstopicutf-8
partitions	partition
error_codeoffset N__name__
__module____qualname____firstlineno__API_KEYAPI_VERSIONr   r
   r	   r   r   r   SCHEMA__static_attributes__r       </venv/lib/python3.13/site-packages/kafka/protocol/produce.pyr   r      sX    GK	5fWo&5e$u%5!# $% 	&Fr!   r   c                   t    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\45      45      4S\	45      rSrg)ProduceResponse_v1   r      r   r   r   r   r   r   r   throttle_time_msr   Nr   r   r!   r"   r$   r$      sb    GK	5fWo&5e$u%5!# $% 	& 
U#Fr!   r$   c                   z    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\4S\45      45      4S\	45      rSrg)ProduceResponse_v2"   r      r   r   r   r   r   r   r   	timestampr'   r   Nr   r   r!   r"   r)   r)   "   sj    GK	5fWo&5e$u%5!e$	& '( 	) 
U#	Fr!   r)   c                   4    \ rS rSrSrSr\R                  rSrg)ProduceResponse_v31   r      r   N)	r   r   r   r   r   r   r)   r   r    r   r!   r"   r.   r.   1   s    GK&&Fr!   r.   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v48   
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 <= 3
r      r   N)
r   r   r   r   __doc__r   r   r.   r   r    r   r!   r"   r2   r2   8   s     GK&&Fr!   r2   c                       \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\4S\4S\45      45      4S\	45      rSrg)ProduceResponse_v5B   r      r   r   r   r   r   r   r   r,   log_start_offsetr'   r   Nr   r   r!   r"   r8   r8   B   sr    GK	5fWo&5e$u%5!e$#U+- ./ 	0 
U#
Fr!   r8   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v6R   p
The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
r      r   N)
r   r   r   r   r6   r   r   r8   r   r    r   r!   r"   r=   r=   R        GK&&Fr!   r=   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v7[   >
V7 bumped up to indicate ZStandard capability. (see KIP-110)
r   r   r   N)
r   r   r   r   r6   r   r   r=   r   r    r   r!   r"   rC   rC   [   rA   r!   rC   c                       \ rS rSrSrSrSr\" S\" S\	" S5      4S\" S	\
4S
\4S\4S\4S\45      S\" S\
4S\	" S5      45      4S\	" S5      445      4S\
45      rSrg)ProduceResponse_v8d   z^
V8 bumped up to add two new fields record_errors offset list and error_message
(See KIP-467)
r      r   r   r   r   r   r   r   r,   r;   record_errorsbatch_indexbatch_index_error_messageerror_messager'   r   N)r   r   r   r   r6   r   r   r   r
   r	   r   r   r   r   r    r   r!   r"   rG   rG   d   s     GK	5fWo&5e$u%5!e$#U+- !5"E*0&/B$  !&/2 	 
U#Fr!   rG   c                       \ rS rSrSrS rSrg)ProduceRequest~   r   c                 &    U R                   S:X  a  gg)Nr   FT)required_acks)selfs    r"   expect_responseProduceRequest.expect_response   s    "r!   r   N)r   r   r   r   r   rT   r    r   r!   r"   rO   rO   ~   s    Gr!   rO   c                   t    \ rS rSrSr\r\" S\4S\	4S\
" S\" S5      4S\
" S	\	4S
\45      45      45      rSrg)ProduceRequest_v0   r   rR   timeoutr   r   r   r   r   recordsr   N)r   r   r   r   r   r   RESPONSE_TYPEr   r   r   r
   r	   r   r   r    r   r!   r"   rW   rW      s`    K&M	% 	E	5fWo&5e$E"$ %& 	'Fr!   rW   c                   4    \ rS rSrSr\r\R                  rSr	g)ProduceRequest_v1   r&   r   N)
r   r   r   r   r   r$   r[   rW   r   r    r   r!   r"   r]   r]          K&M%%Fr!   r]   c                   4    \ rS rSrSr\r\R                  rSr	g)ProduceRequest_v2   r+   r   N)
r   r   r   r   r   r)   r[   r]   r   r    r   r!   r"   ra   ra      r_   r!   ra   c                       \ rS rSrSr\r\" S\" S5      4S\	4S\
4S\" S\" S5      4S	\" S
\
4S\45      45      45      rSrg)ProduceRequest_v3   r0   transactional_idr   rR   rY   r   r   r   r   rZ   r   N)r   r   r   r   r   r.   r[   r   r	   r   r   r
   r   r   r    r   r!   r"   rd   rd      sl    K&M	VG_-	% 	E	5fWo&5e$E"$ %& 	'		Fr!   rd   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v4   r4   r5   r   N)r   r   r   r   r6   r   r2   r[   rd   r   r    r   r!   r"   rh   rh           K&M%%Fr!   rh   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v5   z
Same as v4. The version number is bumped since the v5 response includes an additional
partition level field: the log_start_offset.
r:   r   N)r   r   r   r   r6   r   r8   r[   rh   r   r    r   r!   r"   rl   rl      rj   r!   rl   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v6   r?   r@   r   N)r   r   r   r   r6   r   r=   r[   rl   r   r    r   r!   r"   ro   ro           K&M%%Fr!   ro   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v7   rE   r   r   N)r   r   r   r   r6   r   rC   r[   ro   r   r    r   r!   r"   rs   rs      rq   r!   rs   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v8   zs
V8 bumped up to add two new fields record_errors offset list and error_message to PartitionResponse
(See KIP-467)
rI   r   N)r   r   r   r   r6   r   rG   r[   rs   r   r    r   r!   r"   rv   rv      rj   r!   rv   N)!
__future__r   kafka.protocol.apir   r   kafka.protocol.typesr   r   r   r	   r
   r   r   r   r$   r)   r.   r2   r8   r=   rC   rG   rO   rW   r]   ra   rd   rh   rl   ro   rs   rv   ProduceResponser   r!   r"   <module>r|      s@   & 0 R R R
 
  ' '' '  ' '' ' 4W  & && &  & && && && && & (*;(*;(*; *,>*,>*,>r!   