
    Ii x                        S SK Jr   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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\\\\/r\\\\/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* " S% S&\5      r+ " S' S(\5      r,\+/r-\,/r. " S) S*\5      r/ " S+ S,\5      r0 " S- S.\5      r1 " S/ S0\5      r2 " S1 S2\5      r3 " S3 S4\5      r4\2\3\4/r5\/\0\1/r6 " S5 S6\5      r7 " S7 S8\5      r8 " S9 S:\5      r9 " S; S<\5      r: " S= S>\5      r; " S? S@\5      r< " SA SB\5      r= " SC SD\5      r>\;\<\=\>/r?\7\8\9\:/r@ " SE SF\5      rA " SG SH\5      rB " SI SJ\5      rC " SK SL\5      rD " SM SN\5      rE " SO SP\5      rF\D\E\F/rG\A\B\C/rH " SQ SR\5      rI " SS ST\5      rJ " SU SV\5      rK " SW SX\5      rL\K\L/rM\I\J/rN " SY SZ\5      rO " S[ S\\5      rP " S] S^\5      rQ " S_ S`\5      rR\Q\R/rS\O\P/rT " Sa Sb\5      rU " Sc Sd\5      rV " Se Sf\5      rW " Sg Sh\5      rX\W\X/rY\U\X/rZ " Si Sj\5      r[ " Sk Sl\5      r\ " Sm Sn\5      r] " So Sp\5      r^ " Sq Sr\5      r_ " Ss St\5      r`\^\_\`/ra\[\\\]/rb " Su Sv\5      rc " Sw Sx\5      rd\c/re\d/rf " Sy Sz\5      rg " S{ S|\5      rh " S} S~\5      ri " S S\5      rj\i\j/rk\g\h/rl " S S\5      rm " S S\5      rn " S S\5      ro " S S\5      rp\o\p/rq\m\n/rr " S S\5      rs " S S\5      rt " S S\5      ru " S S\5      rv\u\v/rw\s\t/rx " S S\5      ry " S S\5      rz\z/r{\y/r| " S S\5      r} " S S\5      r~\~/r\}/r " S S\5      r " S S\5      r\/r\/r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r\\/r\\/rg! \ a
    S SKJr   GNIf = f)    )absolute_import)IntEnum)RequestResponse)ArrayBooleanBytesInt8Int16Int32Int64SchemaStringFloat64CompactStringCompactArrayTaggedFieldsc            	       R    \ rS rSrSrSr\" S\" S\" S5      4S\	45      45      r
Srg	)
CreateTopicsResponse_v0      r   topic_errorstopicutf-8
error_code N__name__
__module____qualname____firstlineno__API_KEYAPI_VERSIONr   r   r   r   SCHEMA__static_attributes__r       :/venv/lib/python3.13/site-packages/kafka/protocol/admin.pyr   r      s9    GK	fWo&5!# 	$Fr&   r   c                   d    \ rS rSrSrSr\" S\" S\" S5      4S\	4S\" S5      45      45      r
S	rg
)CreateTopicsResponse_v1   r      r   r   r   r   error_messager   Nr   r   r&   r'   r)   r)      sE    GK	fWo&5!fWo.0 	1Fr&   r)   c                   j    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\
4S	\	" S5      45      45      rS
rg)CreateTopicsResponse_v2#   r      throttle_time_msr   r   r   r   r,   r   Nr   r   r    r!   r"   r#   r   r   r   r   r   r$   r%   r   r&   r'   r.   r.   #   M    GK	U#	fWo&5!fWo.0 	1Fr&   r.   c                   4    \ rS rSrSrSr\R                  rSrg)CreateTopicsResponse_v3.   r      r   N)	r   r   r    r!   r"   r#   r.   r$   r%   r   r&   r'   r5   r5   .       GK$++Fr&   r5   c                       \ rS rSrSrSr\r\" S\	" S\
" S5      4S\4S\4S	\	" S
\4S\	" \5      45      4S\	" S\
" S5      4S\
" S5      45      45      4S\45      rSrg)CreateTopicsRequest_v04   r   r   create_topic_requestsr   r   num_partitionsreplication_factorreplica_assignmentpartition_idreplicasconfigs
config_keyconfig_valuetimeoutr   N)r   r   r    r!   r"   r#   r   RESPONSE_TYPEr   r   r   r   r   r$   r%   r   r&   r'   r:   r:   4   s    GK+M	 %fWo&u%!5)!5'U5\*$, - vg/13 4	#5 		6 
EFr&   r:   c                       \ rS rSrSrSr\r\" S\	" S\
" S5      4S\4S\4S	\	" S
\4S\	" \5      45      4S\	" S\
" S5      4S\
" S5      45      45      4S\4S\45      rSrg)CreateTopicsRequest_v1G   r   r+   r<   r   r   r=   r>   r?   r@   rA   rB   rC   rD   rE   validate_onlyr   N)r   r   r    r!   r"   r#   r)   rF   r   r   r   r   r   r   r$   r%   r   r&   r'   rH   rH   G   s    GK+M	 %fWo&u%!5)!5'U5\*$, - vg/13 4	#5 		6 
E	'"Fr&   rH   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)CreateTopicsRequest_v2[   r   r0   r   N)r   r   r    r!   r"   r#   r.   rF   rH   r$   r%   r   r&   r'   rL   rL   [       GK+M#**Fr&   rL   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)CreateTopicsRequest_v3b   r   r7   r   N)r   r   r    r!   r"   r#   r5   rF   rH   r$   r%   r   r&   r'   rP   rP   b   rN   r&   rP   c            	       R    \ rS rSrSrSr\" S\" S\" S5      4S\	45      45      r
Srg	)
DeleteTopicsResponse_v0s      r   topic_error_codesr   r   r   r   Nr   r   r&   r'   rS   rS   s   s9    GK	efWo&5!# 	$Fr&   rS   c            
       X    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\
45      45      rS	rg
)DeleteTopicsResponse_v1}   rU   r+   r1   rV   r   r   r   r   Nr2   r   r&   r'   rX   rX   }   sA    GK	U#	efWo&5!# 	$Fr&   rX   c                   4    \ rS rSrSrSr\R                  rSrg)DeleteTopicsResponse_v2   rU   r0   r   N	r   r   r    r!   r"   r#   rX   r$   r%   r   r&   r'   r[   r[      r8   r&   r[   c                   4    \ rS rSrSrSr\R                  rSrg)DeleteTopicsResponse_v3   rU   r7   r   Nr]   r   r&   r'   r_   r_      r8   r&   r_   c                   R    \ rS rSrSrSr\r\" S\	" \
" S5      5      4S\45      rSrg)	DeleteTopicsRequest_v0   rU   r   topicsr   rE   r   N)r   r   r    r!   r"   r#   rS   rF   r   r   r   r   r$   r%   r   r&   r'   rb   rb      s4    GK+M	5)*	EFr&   rb   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DeleteTopicsRequest_v1   rU   r+   r   N)r   r   r    r!   r"   r#   rX   rF   rb   r$   r%   r   r&   r'   rf   rf      rN   r&   rf   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DeleteTopicsRequest_v2   rU   r0   r   N)r   r   r    r!   r"   r#   r[   rF   rb   r$   r%   r   r&   r'   ri   ri      rN   r&   ri   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DeleteTopicsRequest_v3   rU   r7   r   N)r   r   r    r!   r"   r#   r_   rF   rb   r$   r%   r   r&   r'   rl   rl      rN   r&   rl   c                   t    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\" S	\4S
\
4S\45      45      45      rSrg)DeleteRecordsResponse_v0      r   r1   rd   namer   
partitionspartition_indexlow_watermarkr   r   N)r   r   r    r!   r"   r#   r   r   r   r   r   r   r$   r%   r   r&   r'   ro   ro      s`    GK	U#	5VG_%5"E* %(u%' () 	*Fr&   ro   c                   r    \ rS rSrSrSr\r\" S\	" S\
" S5      4S\	" S\4S	\45      45      4S
\45      rSrg)DeleteRecordsRequest_v0   rq   r   rd   rr   r   rs   rt   offset
timeout_msr   N)r   r   r    r!   r"   r#   ro   rF   r   r   r   r   r   r$   r%   r   r&   r'   rw   rw      s_    GK,M	5VG_%5"E*5!# $% 	&
 
uFr&   rw   c                   d    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\	" S5      45      45      r
S	rg
)ListGroupsResponse_v0      r   r   groupsgroupr   protocol_typer   N)r   r   r    r!   r"   r#   r   r   r   r   r$   r%   r   r&   r'   r|   r|      sE    GK	u	5fWo&fWo.0 	1Fr&   r|   c                   j    \ rS rSrSrSr\" S\4S\4S\	" S\
" S5      4S	\
" S5      45      45      rS
rg)ListGroupsResponse_v1   r~   r+   r1   r   r   r   r   r   r   Nr   r   r    r!   r"   r#   r   r   r   r   r   r$   r%   r   r&   r'   r   r      sM    GK	U#	u	5fWo&fWo.0 	1Fr&   r   c                   4    \ rS rSrSrSr\R                  rSrg)ListGroupsResponse_v2   r~   r0   r   N)	r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r   r          GK"))Fr&   r   c                   .    \ rS rSrSrSr\r\" 5       r	Sr
g)ListGroupsRequest_v0   r~   r   r   N)r   r   r    r!   r"   r#   r|   rF   r   r$   r%   r   r&   r'   r   r      s    GK)MXFr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ListGroupsRequest_v1   r~   r+   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r          GK)M!((Fr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ListGroupsRequest_v2i  r~   r+   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r     r   r&   r   c                       \ rS rSrSrSr\" S\" S\4S\	" S5      4S\	" S5      4S	\	" S5      4S
\	" S5      4S\" S\	" S5      4S\	" S5      4S\	" S5      4S\
4S\
45      45      45      rSrg)DescribeGroupsResponse_v0i     r   r   r   r   r   stater   protocolmembers	member_id	client_idclient_hostmember_metadatamember_assignmentr   N)r   r   r    r!   r"   r#   r   r   r   r   r	   r$   r%   r   r&   r'   r   r     s    GK	55!fWo&fWo&fWo.)fWo.fWo.w0"E*$e,. /0 	1Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\
" S5      4S
\
" S5      4S\
" S5      4S\" S\
" S5      4S\
" S5      4S\
" S5      4S\4S\45      45      45      rSrg)DescribeGroupsResponse_v1i*  r   r+   r1   r   r   r   r   r   r   r   r   r   r   r   r   r   r   Nr   r   r    r!   r"   r#   r   r   r   r   r   r	   r$   r%   r   r&   r'   r   r   *  s    GK	U#	55!fWo&fWo&fWo.)fWo.fWo.w0"E*$e,. /0 	1Fr&   r   c                   4    \ rS rSrSrSr\R                  rSrg)DescribeGroupsResponse_v2i>  r   r0   r   N)	r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r   r   >  s    GK&--Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\
" S5      4S
\
" S5      4S\
" S5      4S\" S\
" S5      4S\
" S5      4S\
" S5      4S\4S\45      45      S\445      rSrg)DescribeGroupsResponse_v3iD  r   r7   r1   r   r   r   r   r   r   r   r   r   r   r   r   r   authorized_operationsr   Nr   r   r&   r'   r   r   D  s    GK	U#	55!fWo&fWo&fWo.)fWo.fWo.w0"E*$e,. /0 %e,	.Fr&   r   c                   L    \ rS rSrSrSr\r\" S\	" \
" S5      5      45      rSrg)DescribeGroupsRequest_v0iY  r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r   r$   r%   r   r&   r'   r   r   Y  s,    GK-M	5)*Fr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DescribeGroupsRequest_v1ib  r   r+   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r   b      GK-M%,,Fr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DescribeGroupsRequest_v2ii  r   r0   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r   i  r   r&   r   c                   R    \ rS rSrSrSr\r\" S\	" \
" S5      5      4S\45      rSrg)	DescribeGroupsRequest_v3ip  r   r7   r   r   include_authorized_operationsr   N)r   r   r    r!   r"   r#   r   rF   r   r   r   r   r$   r%   r   r&   r'   r   r   p  s4    GK-M	5)*	('2Fr&   r   c                       \ rS rSrSrSr\" S\4S\4S\	" S5      4S\
" S	\4S
\	" S5      4S\
" S\	" S5      4S\	" S5      4S\4S\45      45      45      rSrg)DescribeAclsResponse_v0i     r   r1   r   r,   r   	resourcesresource_typeresource_nameacls	principalhost	operationpermission_typer   Nr   r   r    r!   r"   r#   r   r   r   r   r   r
   r$   r%   r   r&   r'   r   r     s    GK	U#	u	&/*	ed#fWo.UfWo.)d#"D)	+ ,- 	.	Fr&   r   c                       \ rS rSrSrSr\" S\4S\4S\	" S5      4S\
" S	\4S
\	" S5      4S\4S\
" S\	" S5      4S\	" S5      4S\4S\45      45      45      rSrg)DescribeAclsResponse_v1i  r   r+   r1   r   r,   r   r   r   r   resource_pattern_typer   r   r   r   r   r   Nr   r   r&   r'   r   r     s    GK	U#	u	&/*	ed#fWo.$d+UfWo.)d#"D)	+ ,	- 	.	Fr&   r   c                   4    \ rS rSrSrSr\R                  rSrg)DescribeAclsResponse_v2i  r   r0   r   N)	r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r   r     r8   r&   r   c            	       v    \ rS rSrSrSr\r\" S\	4S\
" S5      4S\
" S5      4S\
" S5      4S	\	4S
\	45      rSrg)DescribeAclsRequest_v0i  r   r   r   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r
   r   r$   r%   r   r&   r'   r   r     sW    GK+M	$	&/*	fWo&	!	d	D!Fr&   r   c            
       |    \ rS rSrSrSr\r\" S\	4S\
" S5      4S\	4S\
" S5      4S	\
" S5      4S
\	4S\	45      rSrg)DescribeAclsRequest_v1i  r   r+   r   r   r   resource_pattern_type_filterr   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r
   r   r$   r%   r   r&   r'   r   r     s_    GK+M	$	&/*	'.	fWo&	!	d	D!Fr&   r   c                   <    \ rS rSrSrSrSr\r\	R                  r
Srg)DescribeAclsRequest_v2i  z
Enable flexible version
r   r0   r   N)r   r   r    r!   __doc__r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r     s#     GK+M#**Fr&   r   c                   X    \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      45      45      rS	rg
)CreateAclsResponse_v0i     r   r1   creation_responsesr   r,   r   r   N)r   r   r    r!   r"   r#   r   r   r   r   r   r$   r%   r   r&   r'   r   r     sA    GK	U#	u5!fWo. 0 	1Fr&   r   c                   4    \ rS rSrSrSr\R                  rSrg)CreateAclsResponse_v1i  r   r+   r   N)	r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r   r     r   r&   r   c                       \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\" S5      4S	\" S5      4S
\
4S\
45      45      rSrg)CreateAclsRequest_v0i  r   r   	creationsr   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r$   r%   r   r&   r'   r   r     sf    GK)M	ed#fWo.&/*VG_%$%' 	(Fr&   r   c                       \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\
4S	\" S5      4S
\" S5      4S\
4S\
45      45      rSrg)CreateAclsRequest_v1i  r   r+   r   r   r   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r$   r%   r   r&   r'   r   r     sn    GK)M	ed#fWo.$d+&/*VG_%$%' 	(	Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\" S\	4S\
" S5      4S
\4S\
" S5      4S\
" S5      4S\
" S5      4S\4S\45      45      45      rSrg)DeleteAclsResponse_v0i     r   r1   filter_responsesr   r,   r   matching_aclsr   r   r   r   r   r   r   Nr   r   r    r!   r"   r#   r   r   r   r   r   r
   r$   r%   r   r&   r'   r   r     s    GK	U#	U5!fWo.eu% &/2 $' &/2fWo.)d#"D)+ ,- 	.Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\" S\	4S\
" S5      4S
\4S\
" S5      4S\4S\
" S5      4S\
" S5      4S\4S\45	      45      45      rSrg)DeleteAclsResponse_v1i  r   r+   r1   r   r   r,   r   r   r   r   r   r   r   r   r   r   Nr   r   r&   r'   r   r     s    GK	U#	U5!fWo.eu% &/2 $' &/2($/fWo.)d#"D)	+ 	,- 	.Fr&   r   c                       \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\" S5      4S	\" S5      4S
\
4S\
45      45      rSrg)DeleteAclsRequest_v0i/  r   r   filtersr   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r$   r%   r   r&   r'   r   r   /  sf    GK)M	Ed#fWo.&/*VG_%$%' 	(Fr&   r   c                       \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\
4S	\" S5      4S
\" S5      4S\
4S\
45      45      rSrg)DeleteAclsRequest_v1i=  r   r+   r   r   r   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r$   r%   r   r&   r'   r   r   =  sn    GK)M	Ed#fWo.+T2&/*VG_%$%' 	(	Fr&   r   c                   p    \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\4S
\
" S5      45      45      rSrg)AlterConfigsResponse_v0iO  !   r   r1   r   r   r,   r   r   r   r   Nr   r   r&   r'   r   r   O  sU    GK	U#	e5!fWo.d#fWo.	0 	1Fr&   r   c                   4    \ rS rSrSrSr\R                  rSrg)AlterConfigsResponse_v1i\  r   r+   r   N)	r   r   r    r!   r"   r#   r   r$   r%   r   r&   r'   r   r   \  r8   r&   r   c                       \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\	" S	\" S5      4S
\" S5      45      45      4S\45      rSrg)AlterConfigsRequest_v0ib  r   r   r   r   r   r   config_entriesconfig_namerD   rJ   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r   r$   r%   r   r&   r'   r   r   b  so    GK+M	ed#fWo.uw01 3 45 	6 
'"Fr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)AlterConfigsRequest_v1ip  r   r+   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r   r   p  rN   r&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\4S
\
" S5      4S\" S\
" S5      4S\
" S5      4S\4S\4S\45      45      45      rSrg)DescribeConfigsResponse_v0iz      r   r1   r   r   r,   r   r   r   r   config_namesrD   	read_only
is_defaultis_sensitiver   Nr   r   r    r!   r"   r#   r   r   r   r   r   r
   r   r$   r%   r   r&   r'   r   r   z  s    GK	U#	e5!fWo.d#fWo.u11g&w') + ,
- 
	.Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\4S
\
" S5      4S\" S\
" S5      4S\
" S5      4S\4S\4S\4S\" S\
" S5      4S\
" S5      4S\45      45      45      45      rSrg)DescribeConfigsResponse_v1i  r   r+   r1   r   r   r,   r   r   r   r   r   rD   r   config_sourcer   config_synonymsr   r   Nr   r   r&   r'   r   r         GK	U#	e5!fWo.d#fWo.u11g& $')"E"F7O4#VG_5$d+%- .	 / 	01 	2Fr&   r   c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\4S
\
" S5      4S\" S\
" S5      4S\
" S5      4S\4S\4S\4S\" S\
" S5      4S\
" S5      4S\45      45      45      45      rSrg)DescribeConfigsResponse_v2i  r   r0   r1   r   r   r,   r   r   r   r   r   rD   r   r   r   r   r   r   Nr   r   r&   r'   r   r     r   r&   r   c                   t    \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\	" \" S5      5      45      45      rS	rg
)DescribeConfigsRequest_v0i  r   r   r   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r$   r%   r   r&   r'   r   r     sO    GK.M	ed#fWo.U6'?346 	7Fr&   r   c                   z    \ rS rSrSrSr\r\" S\	" S\
4S\" S5      4S\	" \" S5      5      45      4S	\45      rS
rg)DescribeConfigsRequest_v1i  r   r+   r   r   r   r   r   include_synonymsr   N)r   r   r    r!   r"   r#   r   rF   r   r   r
   r   r   r$   r%   r   r&   r'   r   r     sY    GK.M	ed#fWo.U6'?346 	7 
W%Fr&   r   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DescribeConfigsRequest_v2i  r   r0   r   N)r   r   r    r!   r"   r#   r   rF   r   r$   r%   r   r&   r'   r  r    s    GK.M&--Fr&   r  c                       \ rS rSrSrSr\" S\4S\" S\	4S\
" S5      4S	\" S
\
" S5      4S\" S\4S\4S\4S\45      45      45      45      rSrg)DescribeLogDirsResponse_v0i  r/   r   r1   log_dirsr   log_dirr   rd   rr   rs   rt   partition_size
offset_lagis_future_keyr   N)r   r   r    r!   r"   r#   r   r   r   r   r   r   r   r$   r%   r   r&   r'   r  r    s    GK	U#	U5!w(u)u&.%u-!5)$g.	   
 	Fr&   r  c            	       V    \ rS rSrSrSr\r\" S\	" S\
" S5      4S\45      45      rSrg	)
DescribeLogDirsRequest_v0i  r/   r   rd   r   r   rs   r   N)r   r   r    r!   r"   r#   r  rF   r   r   r   r   r$   r%   r   r&   r'   r
  r
    s>    GK.M!6'?3&.! Fr&   r
  c                   H    \ rS rSrSrSr\" S\4S\" S5      4S\	45      r
Srg	)
SaslAuthenticateResponse_v0i
  $   r   r   r,   r   sasl_auth_bytesr   N)r   r   r    r!   r"   r#   r   r   r   r	   r$   r%   r   r&   r'   r  r  
  s2    GK	u	&/*	E"Fr&   r  c                   N    \ rS rSrSrSr\" S\4S\" S5      4S\	4S\
45      rS	rg
)SaslAuthenticateResponse_v1i  r  r+   r   r,   r   r  session_lifetime_msr   N)r   r   r    r!   r"   r#   r   r   r   r	   r   r$   r%   r   r&   r'   r  r    s:    GK	u	&/*	E"	&	Fr&   r  c                   4    \ rS rSrSrSr\r\" S\	45      r
Srg)SaslAuthenticateRequest_v0i  r  r   r  r   N)r   r   r    r!   r"   r#   r  rF   r   r	   r$   r%   r   r&   r'   r  r    s#    GK/M	E"Fr&   r  c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)SaslAuthenticateRequest_v1i(  r  r+   r   N)r   r   r    r!   r"   r#   r  rF   r  r$   r%   r   r&   r'   r  r  (  s    GK/M'..Fr&   r  c                   j    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\
4S	\	" S5      45      45      rS
rg)CreatePartitionsResponse_v0i7  %   r   r1   r   r   r   r   r,   r   Nr2   r   r&   r'   r  r  7  r3   r&   r  c                   4    \ rS rSrSrSr\R                  rSrg)CreatePartitionsResponse_v1iC  r  r+   r   N)	r   r   r    r!   r"   r#   r  r$   r%   r   r&   r'   r  r  C  s    GK(//Fr&   r  c                       \ rS rSrSrSr\r\" S\	" S\
" S5      4S\" S\4S	\	" \	" \5      5      45      45      4S
\4S\45      rSrg)CreatePartitionsRequest_v0iI  r  r   topic_partitionsr   r   new_partitionscount
assignmentrE   rJ   r   N)r   r   r    r!   r"   r#   r  rF   r   r   r   r   r   r$   r%   r   r&   r'   r  r  I  sp    GK/M	UfWo&v% uU5\23 5 67 	8
 
E	'"Fr&   r  c                   8    \ rS rSrSrSr\R                  r\r	Sr
g)CreatePartitionsRequest_v1iX  r  r+   r   N)r   r   r    r!   r"   r#   r  r$   r  rF   r%   r   r&   r'   r"  r"  X  s    GK'..F/Mr&   r"  c            
       X    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\
45      45      rS	rg
)DeleteGroupsResponse_v0ig  *   r   r1   resultsgroup_idr   r   r   Nr2   r   r&   r'   r$  r$  g  sA    GK	U#	E)5!# 	$Fr&   r$  c                   4    \ rS rSrSrSr\R                  rSrg)DeleteGroupsResponse_v1ir  r%  r+   r   N)	r   r   r    r!   r"   r#   r$  r$   r%   r   r&   r'   r)  r)  r  r8   r&   r)  c                   L    \ rS rSrSrSr\r\" S\	" \
" S5      5      45      rSrg)DeleteGroupsRequest_v0ix  r%  r   groups_namesr   r   N)r   r   r    r!   r"   r#   r$  rF   r   r   r   r$   r%   r   r&   r'   r+  r+  x  s,    GK+M	vg/0Fr&   r+  c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)DeleteGroupsRequest_v1i  r%  r+   r   N)r   r   r    r!   r"   r#   r)  rF   r+  r$   r%   r   r&   r'   r.  r.    rN   r&   r.  c                       \ rS rSrSrSr\" S\4S\4S\	" S5      4S\
" S	\
" S
\	" S5      4S\	" S5      45      4S\
" S\	" S5      4S\45      45      45      rSrg)DescribeClientQuotasResponse_v0i  0   r   r1   r   r,   r   entriesentityentity_typeentity_namevaluesrr   valuer   N)r   r   r    r!   r"   r#   r   r   r   r   r   r   r$   r%   r   r&   r'   r0  r0    s    GK	U#	u	&/*	Euw0w02 3 u)'"$ %	& 	'	Fr&   r0  c                   n    \ rS rSrSrSr\r\" S\	" S\
" S5      4S\4S\
" S5      45      4S	\45      rS
rg)DescribeClientQuotasRequest_v0i  r1  r   
componentsr4  r   
match_typematchstrictr   N)r   r   r    r!   r"   r#   r0  rF   r   r   r   r
   r   r$   r%   r   r&   r'   r9  r9    sT    GK3M	uF7O,4 fWo&
 	
 
7Fr&   r9  c                       \ rS rSrSrSr\" S\4S\4S\	" S5      4S\
" S	\	" S5      4S
\
" S\4S\4S\	" S5      4S\45      4S\45      4S\45      rSrSrg)&AlterPartitionReassignmentsResponse_v0i  -   r   r1   r   r,   r   	responsesrr   rs   rt   tagsTr   Nr   r   r    r!   r"   r#   r   r   r   r   r   r   r$   FLEXIBLE_VERSIONr%   r   r&   r'   r?  r?    s    GK	U#	u	-01	l]7+,<"E*u% -"89&	  \"	
 		 
F  r&   r?  c                       \ rS rSrSrSrSr\r\	" S\
4S\" S\" S5      4S	\" S
\
4S\" \
5      4S\45      4S\45      4S\45      rSrg)%AlterPartitionReassignmentsRequest_v0i  Tr@  r   rz   rd   rr   r   rs   rt   rA   rB  r   N)r   r   r    r!   rD  r"   r#   r?  rF   r   r   r   r   r   r$   r%   r   r&   r'   rF  rF    s    GK:M	u	<]7+,<"E*\%01& 
 \"
 	 
Fr&   rF  c                       \ rS rSrSrSr\" S\4S\4S\	" S5      4S\
" S	\	" S5      4S
\
" S\4S\
" \5      4S\
" \5      4S\
" \5      4S\45      4S\45      4S\45      rSrSrg)%ListPartitionReassignmentsResponse_v0i  r6   r   r1   r   r,   r   rd   rr   rs   rt   rA   adding_replicasremoving_replicasrB  Tr   NrC  r   r&   r'   rH  rH    s    GK	U#	u	-01	<]7+,<"E*\%01"L$78$l5&9:&  \"

 
	 
F" r&   rH  c                   x    \ rS rSrSrSrSr\r\	" S\
4S\" S\" S5      4S	\" \
5      4S
\45      4S
\45      rSrg)$ListPartitionReassignmentsRequest_v0i  Tr6   r   rz   rd   rr   r   rt   rB  r   N)r   r   r    r!   rD  r"   r#   rH  rF   r   r   r   r   r   r$   r%   r   r&   r'   rL  rL    sd    GK9M	u	<]7+,U 34\"
 	
 
Fr&   rL  c                       \ rS rSrSrSr\" S\4S\4S\	" S\
" S5      4S	\	" S
\4S\4S\
" S5      45      45      45      rSrg)ElectLeadersResponse_v0i  +   r+   r1   r   replication_election_resultsr   r   partition_resultr@   r,   r   Nr   r   r&   r'   rN  rN    l    GK	U#	u	'fWo&'u% &/2" *
 	Fr&   rN  c                   n    \ rS rSrSrSr\r\" S\	4S\
" S\" S5      4S\
" \5      45      4S	\45      rS
rg)ElectLeadersRequest_v0i%  rO  r+   election_typer  r   r   partition_idsrE   r   N)r   r   r    r!   r"   r#   rN  rF   r   r
   r   r   r   r$   r%   r   r&   r'   rT  rT  %  T    GK+M	$	UfWo&eEl+
 	 
EFr&   rT  c                       \ rS rSrSrSr\" S\4S\4S\	" S\
" S5      4S	\	" S
\4S\4S\
" S5      45      45      45      rSrg)ElectLeadersResponse_v1i3  rO  r+   r1   r   rP  r   r   rQ  r@   r,   r   Nr   r   r&   r'   rY  rY  3  rR  r&   rY  c                   n    \ rS rSrSrSr\r\" S\	4S\
" S\" S5      4S\
" \5      45      4S	\45      rS
rg)ElectLeadersRequest_v1iD  rO  r+   rU  r  r   r   rV  rE   r   N)r   r   r    r!   r"   r#   rY  rF   r   r
   r   r   r   r$   r%   r   r&   r'   r[  r[  D  rW  r&   r[  c                        \ rS rSrSrSrSrSrg)ElectionTypeiR  zLeader election type
    )r   r+   r   N)r   r   r    r!   r   	PREFERREDUNCLEANr%   r   r&   r'   r]  r]  R  s     IGr&   r]  N)
__future__r   enumr   ImportErrorkafka.vendor.enum34kafka.protocol.apir   r   kafka.protocol.typesr   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r)   r.   r5   r:   rH   rL   rP   CreateTopicsRequestCreateTopicsResponserS   rX   r[   r_   rb   rf   ri   rl   DeleteTopicsRequestDeleteTopicsResponsero   rw   DeleteRecordsResponseDeleteRecordsRequestr|   r   r   r   r   r   ListGroupsRequestListGroupsResponser   r   r   r   r   r   r   r   DescribeGroupsRequestDescribeGroupsResponser   r   r   r   r   r   DescribeAclsRequestDescribeAclsResponser   r   r   r   CreateAclsRequestCreateAclsResponser   r   r   r   DeleteAclsRequestDeleteAclsResponser   r   r   r   AlterConfigsRequestAlterConfigsResponser   r   r   r   r   r  DescribeConfigsRequestDescribeConfigsResponser  r
  DescribeLogDirsResponseDescribeLogDirsRequestr  r  r  r  SaslAuthenticateRequestSaslAuthenticateResponser  r  r  r"  CreatePartitionsRequestCreatePartitionsResponser$  r)  r+  r.  DeleteGroupsRequestDeleteGroupsResponser0  r9  DescribeClientQuotasRequestDescribeClientQuotasResponser?  rF  "AlterPartitionReassignmentsRequest#AlterPartitionReassignmentsResponserH  rL  !ListPartitionReassignmentsRequest"ListPartitionReassignmentsResponserN  rT  rY  r[  r]  ElectLeadersRequestElectLeadersResponser   r&   r'   <module>r     s;   &,
 1 V  V  V  Vh h 	h 	,h ,W &W (+W ++W + 22 
 44 h h ,h ,,h ,W +W ++W ++W + 22 
 44 x g  22 /0 H 	H 	*H *7 )7 ))7 ) . 
 0  & (. . *w -w --w -w  66 
 88 h $h &,h ,W W +W + ./EG]^ /1HJab H *H *
7 7  *+?@ +-BC H &H (7 7  *+?@ +-BC 
h 
,h ,W +W + ./EF /1GH  $ , ,	 	
 
. . 8 
  :  *	 	    
( (  / /  :   !< 
	( 	0( 0 0 0  :   !< 
h ,h ,W +W + 2 
 4 
h "W  # 
 $  
X ,G ( 'L%L "'M&N #H .7   &J$J !&K%L "h "W h "W 7  ./EF /1HI k"  ,++,s   Q QQ