o
    `jq                     @   sP  d dl mZ ddlmZmZ ddlmZmZmZm	Z	m
Z
mZmZmZmZmZmZmZmZmZ G dd deZG dd deZG d	d
 d
eZG dd deZG dd deZG dd deZG dd deZG dd deZeeeegZeeeegZG dd deZG dd deZG dd deZ G dd deZ!G dd deZ"G dd  d eZ#G d!d" d"eZ$G d#d$ d$eZ%e"e#e$e%gZ&eee e!gZ'G d%d& d&eZ(G d'd( d(eZ)e(gZ*e)gZ+G d)d* d*eZ,G d+d, d,eZ-G d-d. d.eZ.G d/d0 d0eZ/G d1d2 d2eZ0G d3d4 d4eZ1e/e0e1gZ2e,e-e.gZ3G d5d6 d6eZ4G d7d8 d8eZ5G d9d: d:eZ6G d;d< d<eZ7G d=d> d>eZ8G d?d@ d@eZ9G dAdB dBeZ:G dCdD dDeZ;e8e9e:e;gZ<e4e5e6e7gZ=G dEdF dFeZ>G dGdH dHeZ?G dIdJ dJeZ@G dKdL dLeZAG dMdN dNeZBG dOdP dPeZCeAeBeCgZDe>e?e@gZEG dQdR dReZFG dSdT dTeZGG dUdV dVeZHG dWdX dXeZIeHeIgZJeFeGgZKG dYdZ dZeZLG d[d\ d\eZMG d]d^ d^eZNG d_d` d`eZOeNeOgZPeLeMgZQG dadb dbeZRG dcdd ddeZSG dedf dfeZTG dgdh dheZUeTeUgZVeReUgZWG didj djeZXG dkdl dleZYG dmdn dneZZG dodp dpeZ[G dqdr dreZ\G dsdt dteZ]e[e\e]gZ^eXeYeZgZ_G dudv dveZ`G dwdx dxeZae`gZbeagZcG dydz dzeZdG d{d| d|eZeG d}d~ d~eZfG dd deZgefeggZhedeegZiG dd deZjG dd deZkG dd deZlG dd deZmelemgZnejekgZoG dd deZpG dd deZqeqgZrepgZsG dd deZtG dd deZueugZvetgZwG dd deZxG dd deZyeygZzexgZ{G dd deZ|G dd deZ}G dd deZ~G dd deZG dd deZe~egZe|e}gZdS )    )IntEnum   )RequestResponse)ArrayBooleanBytesInt8Int16Int32Int64SchemaStringFloat64CompactStringCompactArrayTaggedFieldsBitFieldc                   @   :   e Zd ZdZdZedededfdeffZ	ddiZ
dS )	CreateTopicsResponse_v0   r   topicsnameutf-8
error_codetopic_errorsN__name__
__module____qualname__API_KEYAPI_VERSIONr   r   r   r
   SCHEMAALIASES r$   r$   V/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/admin.pyr          
r   c                   @   sB   e Zd ZdZdZedededfdefdedffZ	e
jZdS )	CreateTopicsResponse_v1r   r   r   r   r   r   error_messageN)r   r   r   r    r!   r   r   r   r
   r"   r   r#   r$   r$   r$   r%   r'      s    


r'   c                	   @   sH   e Zd ZdZdZedefdededfde	fdedffZ
ejZd	S )
CreateTopicsResponse_v2r      throttle_time_msr   r   r   r   r(   N)r   r   r   r    r!   r   r   r   r   r
   r"   r'   r#   r$   r$   r$   r%   r)       s    


r)   c                   @       e Zd ZdZdZejZejZdS )CreateTopicsResponse_v3r      N)r   r   r   r    r!   r)   r"   r#   r$   r$   r$   r%   r-   -   
    
r-   c                   @   s|   e Zd ZdZdZedededfdefde	fded	efd
eeffdededfdedfffdefZ
dddZdS )CreateTopicsRequest_v0r   r   r   r   r   num_partitionsreplication_factorassignmentspartition_index
broker_idsconfigsvalue
timeout_ms)create_topic_requeststimeoutN)r   r   r   r    r!   r   r   r   r   r
   r"   r#   r$   r$   r$   r%   r0   4   s,    





r0   c                   @   s~   e Zd ZdZdZedededfdefde	fded	efd
eeffdededfdedfffdefde
fZejZdS )CreateTopicsRequest_v1r   r   r   r   r   r1   r2   r3   r4   r5   r6   r7   r8   validate_onlyN)r   r   r   r    r!   r   r   r   r   r
   r   r"   r0   r#   r$   r$   r$   r%   r;   J   s*    





r;   c                   @   r,   )CreateTopicsRequest_v2r   r*   Nr   r   r   r    r!   r;   r"   r#   r$   r$   r$   r%   r=   ^   r/   r=   c                   @   r,   )CreateTopicsRequest_v3r   r.   Nr>   r$   r$   r$   r%   r?   e   r/   r?   c                   @   r   )	DeleteTopicsResponse_v0   r   	responsesr   r   r   topic_error_codesNr   r$   r$   r$   r%   r@   v   r&   r@   c                   @   s>   e Zd ZdZdZedefdededfde	ffZ
ejZdS )	DeleteTopicsResponse_v1rA   r   r+   rB   r   r   r   N)r   r   r   r    r!   r   r   r   r   r
   r"   r@   r#   r$   r$   r$   r%   rD      s    

rD   c                   @   r,   )DeleteTopicsResponse_v2rA   r*   Nr   r   r   r    r!   rD   r"   r#   r$   r$   r$   r%   rE      r/   rE   c                   @   r,   )DeleteTopicsResponse_v3rA   r.   NrF   r$   r$   r$   r%   rG      r/   rG   c                   @   s8   e Zd ZdZdZedeedfdefZ	dddZ
dS )DeleteTopicsRequest_v0rA   r   topic_namesr   r8   )r   r:   Nr   r   r   r    r!   r   r   r   r   r"   r#   r$   r$   r$   r%   rH      s    
rH   c                   @   r,   )DeleteTopicsRequest_v1rA   r   Nr   r   r   r    r!   rH   r"   r#   r$   r$   r$   r%   rK      r/   rK   c                   @   r,   )DeleteTopicsRequest_v2rA   r*   NrL   r$   r$   r$   r%   rM      r/   rM   c                   @   r,   )DeleteTopicsRequest_v3rA   r.   NrL   r$   r$   r$   r%   rN      r/   rN   c                   @   sL   e Zd ZdZdZedefdededfdedefd	e	fd
e
fffZdS )DeleteRecordsResponse_v0   r   r+   r   r   r   
partitionsr4   low_watermarkr   N)r   r   r   r    r!   r   r   r   r   r   r
   r"   r$   r$   r$   r%   rO      s    
rO   c                	   @   sF   e Zd ZdZdZedededfdedefde	fffd	efZ
d
S )DeleteRecordsRequest_v0rP   r   r   r   r   rQ   r4   offsetr8   N)r   r   r   r    r!   r   r   r   r   r   r"   r$   r$   r$   r%   rS      s    
rS   c                   @   s<   e Zd ZdZdZedefdededfdedffZ	dS )	ListGroupsResponse_v0   r   r   groupsgroup_idr   protocol_typeN)
r   r   r   r    r!   r   r
   r   r   r"   r$   r$   r$   r%   rU      s    

rU   c                	   @   sB   e Zd ZdZdZedefdefdede	dfde	dffZ
d	S )
ListGroupsResponse_v1rV   r   r+   r   rW   rX   r   rY   N)r   r   r   r    r!   r   r   r
   r   r   r"   r$   r$   r$   r%   rZ      s    

rZ   c                   @      e Zd ZdZdZejZdS )ListGroupsResponse_v2rV   r*   N)r   r   r   r    r!   rZ   r"   r$   r$   r$   r%   r\          
r\   c                   @   s   e Zd ZdZdZe ZdS )ListGroupsRequest_v0rV   r   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r^     r]   r^   c                   @   r[   )ListGroupsRequest_v1rV   r   Nr   r   r   r    r!   r^   r"   r$   r$   r$   r%   r_   
  r]   r_   c                   @   r[   )ListGroupsRequest_v2rV   r   Nr`   r$   r$   r$   r%   ra     r]   ra   c                   @   s   e Zd ZdZdZededefdedfdedfdedfd	edfd
ededfdedfdedfde	fde	fffZ
dS )DescribeGroupsResponse_v0   r   rW   r   rX   r   group_staterY   protocol_datamembers	member_id	client_idclient_hostmember_metadatamember_assignmentN)r   r   r   r    r!   r   r   r
   r   r   r"   r$   r$   r$   r%   rb     s&    






rb   c                   @   s   e Zd ZdZdZedefdedefde	dfde	dfd	e	dfd
e	dfdede	dfde	dfde	dfde
fde
fffZdS )DescribeGroupsResponse_v1rc   r   r+   rW   r   rX   r   rd   rY   re   rf   rg   rh   ri   rj   rk   N)r   r   r   r    r!   r   r   r   r
   r   r   r"   r$   r$   r$   r%   rl   2  s(    






rl   c                   @   r[   )DescribeGroupsResponse_v2rc   r*   N)r   r   r   r    r!   rl   r"   r$   r$   r$   r%   rm   F  r]   rm   c                   @   s   e Zd ZdZdZedefdedefde	dfde	dfd	e	dfd
e	dfdede	dfde	dfde	dfde
fde
ffdeffZdS )DescribeGroupsResponse_v3rc   r.   r+   rW   r   rX   r   rd   rY   re   rf   rg   rh   ri   rj   rk   authorized_operationsN)r   r   r   r    r!   r   r   r   r
   r   r   r   r"   r$   r$   r$   r%   rn   L  s*    






rn   c                   @   (   e Zd ZdZdZedeedfZdS )DescribeGroupsRequest_v0rc   r   rW   r   N	r   r   r   r    r!   r   r   r   r"   r$   r$   r$   r%   rq   a      rq   c                   @   r[   )DescribeGroupsRequest_v1rc   r   Nr   r   r   r    r!   rq   r"   r$   r$   r$   r%   rt   i  r]   rt   c                   @   r[   )DescribeGroupsRequest_v2rc   r*   Nru   r$   r$   r$   r%   rv   o  r]   rv   c                   @   s.   e Zd ZdZdZedeedfdefZ	dS )DescribeGroupsRequest_v3rc   r.   rW   r   include_authorized_operationsN)
r   r   r   r    r!   r   r   r   r   r"   r$   r$   r$   r%   rw   u  s    rw   c                   @   sp   e Zd ZdZdZedefdefdedfde	de
fd	edfd
e	dedfdedfde
fde
fffZdS )DescribeAclsResponse_v0   r   r+   r   r(   r   	resourcesresource_typeresource_nameacls	principalhost	operationpermission_typeNr   r   r   r    r!   r   r   r
   r   r   r	   r"   r$   r$   r$   r%   ry     s$    



ry   c                   @   sv   e Zd ZdZdZedefdefdedfde	de
fd	edfd
e
fde	dedfdedfde
fde
fffZdS )DescribeAclsResponse_v1rz   r   r+   r   r(   r   r{   r|   r}   pattern_typer~   r   r   r   r   Nr   r$   r$   r$   r%   r     s&    



r   c                   @   r[   )DescribeAclsResponse_v2rz   r*   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r     r]   r   c                   @   sX   e Zd ZdZdZedefdedfdedfdedfdefd	efZddddd
Z	dS )DescribeAclsRequest_v0rz   r   resource_type_filterresource_name_filterr   principal_filterhost_filterr   r   )r|   r}   r   r   N
r   r   r   r    r!   r   r	   r   r"   r#   r$   r$   r$   r%   r     s     


	
r   c                	   @   s`   e Zd ZdZdZedefdedfdefdedfdedfd	efd
efZddddddZ	dS )DescribeAclsRequest_v1rz   r   r   r   r   pattern_type_filterr   r   r   r   )r|   r}   resource_pattern_type_filterr   r   Nr   r$   r$   r$   r%   r     s$    




r   c                   @   s   e Zd ZdZdZdZejZdS )DescribeAclsRequest_v2z!
    Enable flexible version
    rz   r*   N)r   r   r   __doc__r    r!   r   r"   r$   r$   r$   r%   r     s
    
r   c                   @   s@   e Zd ZdZdZedefdedefde	dffZ
ddiZd	S )
CreateAclsResponse_v0   r   r+   resultsr   r(   r   creation_responsesN)r   r   r   r    r!   r   r   r   r
   r   r"   r#   r$   r$   r$   r%   r     s    
r   c                   @   r,   )CreateAclsResponse_v1r   r   N)r   r   r   r    r!   r   r"   r#   r$   r$   r$   r%   r     r/   r   c                
   @   R   e Zd ZdZdZededefdedfdedfdedfd	efd
effZ	dS )CreateAclsRequest_v0r   r   	creationsr|   r}   r   r   r   r   r   N
r   r   r   r    r!   r   r   r	   r   r"   r$   r$   r$   r%   r         


r   c                   @   X   e Zd ZdZdZededefdedfdefdedfd	edfd
efdeffZ	dS )CreateAclsRequest_v1r   r   r   r|   r}   r   resource_pattern_typer   r   r   r   Nr   r$   r$   r$   r%   r         


r   c                   @   s   e Zd ZdZdZedefdedefde	dfdedefde	dfd	e
fd
e	dfde	dfde	dfde
fde
fffZddiZdS )DeleteAclsResponse_v0   r   r+   filter_resultsr   r(   r   matching_aclsr|   r}   r   r   r   r   filter_responsesNr   r   r   r    r!   r   r   r   r
   r   r	   r"   r#   r$   r$   r$   r%   r     s,    




r   c                   @   s   e Zd ZdZdZedefdedefde	dfdedefde	dfd	e
fd
e	dfde
fde	dfde	dfde
fde
f	ffZejZdS )DeleteAclsResponse_v1r   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   5  s,    





r   c                
   @   r   )DeleteAclsRequest_v0r   r   filtersr   r   r   r   r   r   r   Nr   r$   r$   r$   r%   r   K  r   r   c                   @   r   )DeleteAclsRequest_v1r   r   r   r   r   r   r   r   r   r   r   Nr   r$   r$   r$   r%   r   Y  r   r   c                
   @   sP   e Zd ZdZdZedefdedefde	dfde
fd	e	dffZd
diZdS )AlterConfigsResponse_v0!   r   r+   rB   r   r(   r   r|   r}   r{   Nr   r$   r$   r$   r%   r   l  s    

	r   c                   @   r,   )AlterConfigsResponse_v1r   r   N)r   r   r   r    r!   r   r"   r#   r$   r$   r$   r%   r   |  r/   r   c                   @   sT   e Zd ZdZdZededefdedfdededfd	edfffd
e	fZ
dS )AlterConfigsRequest_v0r   r   r{   r|   r}   r   r6   r   r7   r<   Nr   r   r   r    r!   r   r   r	   r   r   r"   r$   r$   r$   r%   r     s    


r   c                   @   r[   )AlterConfigsRequest_v1r   r   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r     r]   r   c                   @   s~   e Zd ZdZdZedefdedefde	dfde
fd	e	dfd
ede	dfde	dfdefdefdefffZddiZdS )DescribeConfigsResponse_v0    r   r+   r   r   r(   r   r|   r}   r6   r   r7   	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     s*    



r   c                   @   s   e Zd ZdZdZedefdedefde	dfde
fd	e	dfd
ede	dfde	dfdefde
fdefdede	dfde	dfde
ffffZejZdS )DescribeConfigsResponse_v1r   r   r+   r   r   r(   r   r|   r}   r6   r   r7   r   config_sourcer   synonymssourceN)r   r   r   r    r!   r   r   r   r
   r   r	   r   r"   r   r#   r$   r$   r$   r%   r     s2    






r   c                   @   r,   )DescribeConfigsResponse_v2r   r*   N)r   r   r   r    r!   r   r"   r#   r$   r$   r$   r%   r     r/   r   c                	   @   s@   e Zd ZdZdZededefdedfdeedffZ	dS )	DescribeConfigsRequest_v0r   r   r{   r|   r}   r   configuration_keysNr   r$   r$   r$   r%   r     s    
r   c                	   @   sF   e Zd ZdZdZededefdedfdeedffde	fZ
d	S )
DescribeConfigsRequest_v1r   r   r{   r|   r}   r   r   include_synonymsNr   r$   r$   r$   r%   r     s    
r   c                   @   r[   )DescribeConfigsRequest_v2r   r*   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r     r]   r   c                   @   sr   e Zd ZdZdZedefdedefde	dfded	e	dfd
edefde
fde
fdeffffZddiZdS )DescribeLogDirsResponse_v0#   r   r+   r   r   log_dirr   r   r   rQ   r4   partition_size
offset_lagis_future_keylog_dirsN)r   r   r   r    r!   r   r   r   r
   r   r   r   r"   r#   r$   r$   r$   r%   r     s*    

r   c                   @   s2   e Zd ZdZdZedededfdeffZ	dS )DescribeLogDirsRequest_v0r   r   r   topicr   rQ   N)
r   r   r   r    r!   r   r   r   r   r"   r$   r$   r$   r%   r     s    
r   c                	   @   sJ   e Zd ZdZdZedefdededfde	fdedffZ
d	diZd
S )CreatePartitionsResponse_v0%   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     s    

r   c                   @   r,   )CreatePartitionsResponse_v1r   r   N)r   r   r   r    r!   r   r"   r#   r$   r$   r$   r%   r   ,  r/   r   c                   @   s^   e Zd ZdZdZedededfdedefdeeefffd	efd
e	fZ
dd	dZdS )CreatePartitionsRequest_v0r   r   r   r   r   new_partitionscount
assignmentr8   r<   )topic_partitionsr:   N)r   r   r   r    r!   r   r   r   r   r   r"   r#   r$   r$   r$   r%   r   3  s"    

r   c                   @   r,   )CreatePartitionsRequest_v1r   r   N)r   r   r   r    r!   r   r"   r#   r$   r$   r$   r%   r   F  r/   r   c                   @   s8   e Zd ZdZdZedefdededfde	ffZ
dS )	DeleteGroupsResponse_v0*   r   r+   r   rX   r   r   N)r   r   r   r    r!   r   r   r   r   r
   r"   r$   r$   r$   r%   r   U  s    
r   c                   @   r[   )DeleteGroupsResponse_v1r   r   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r   `  r]   r   c                   @   rp   )DeleteGroupsRequest_v0r   r   groups_namesr   Nrr   r$   r$   r$   r%   r   f  rs   r   c                   @   r[   )DeleteGroupsRequest_v1r   r   N)r   r   r   r    r!   r   r"   r$   r$   r$   r%   r   n  r]   r   c                   @   sl   e Zd ZdZdZedefdefdedfde	de	d	edfd
edffde	dedfde
fffZdS )DescribeClientQuotasResponse_v00   r   r+   r   r(   r   entriesentityentity_typeentity_namevalueskeyr7   N)r   r   r   r    r!   r   r   r
   r   r   r   r"   r$   r$   r$   r%   r   }  s$    



r   c                   @   sB   e Zd ZdZdZedededfdefdedffde	fZ
d	S )
DescribeClientQuotasRequest_v0r   r   
componentsr   r   
match_typematchstrictN)r   r   r   r    r!   r   r   r   r	   r   r"   r$   r$   r$   r%   r     s    

r   c                   @   sv   e Zd ZdZdZedefdefdedfde	dedfd	e	d
efdefdedfde
ffde
ffde
fZdZdS )&AlterPartitionReassignmentsResponse_v0-   r   r+   r   r(   r   rB   r   rQ   r4   tagsTNr   r   r   r    r!   r   r   r
   r   r   r   r"   FLEXIBLE_VERSIONr$   r$   r$   r%   r     s(    



r   c                   @   s`   e Zd ZdZdZdZedefdede	dfded	efd
eefde
ffde
ffde
fZdS )%AlterPartitionReassignmentsRequest_v0Tr   r   r8   r   r   r   rQ   r4   replicasr   Nr   r   r   r   r    r!   r   r   r   r   r   r"   r$   r$   r$   r%   r     s"    

	r   c                   @   s   e Zd ZdZdZedefdefdedfde	dedfd	e	d
efde	efde	efde	efde
ffde
ffde
fZdZdS )%ListPartitionReassignmentsResponse_v0.   r   r+   r   r(   r   r   r   rQ   r4   r   adding_replicasremoving_replicasr   TNr   r$   r$   r$   r%   r     s*    




r   c                   @   sL   e Zd ZdZdZdZedefdede	dfdeefd	e
ffd	e
fZd
S )$ListPartitionReassignmentsRequest_v0Tr   r   r8   r   r   r   partition_indexesr   Nr   r$   r$   r$   r%   r     s    

r   c                   @   sX   e Zd ZdZdZedefdededfdedefd	e	fd
edfffZ
ddiZdS )ElectLeadersResponse_v0+   r   r+   replica_election_resultsr   r   partition_resultpartition_idr   r(   replication_election_resultsNr   r$   r$   r$   r%   r     s     


r   c                   @   s\   e Zd ZdZdZedefdefdede	dfded	efdefd
e	dfffZ
ejZdS )ElectLeadersResponse_v1r   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     s     



r   c                   @   sD   e Zd ZdZdZedededfdeeffdefZ	ddiZ
d	S )
ElectLeadersRequest_v0r   r   r   r   r   rQ   r8   r:   NrJ   r$   r$   r$   r%   r     s    

r   c                   @   sH   e Zd ZdZdZedefdededfdee	ffde	fZ
ejZd	S )
ElectLeadersRequest_v1r   r   election_typer   r   r   rQ   r8   N)r   r   r   r    r!   r   r	   r   r   r   r"   r   r#   r$   r$   r$   r%   r   *  s    


r   c                   @   s   e Zd ZdZdZdZdS )ElectionTypezLeader election type)r   r   N)r   r   r   r   	PREFERREDUNCLEANr$   r$   r$   r%   r   7  s    r   N)enumr   apir   r   typesr   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r'   r)   r-   r0   r;   r=   r?   CreateTopicsRequestCreateTopicsResponser@   rD   rE   rG   rH   rK   rM   rN   DeleteTopicsRequestDeleteTopicsResponserO   rS   DeleteRecordsResponseDeleteRecordsRequestrU   rZ   r\   r^   r_   ra   ListGroupsRequestListGroupsResponserb   rl   rm   rn   rq   rt   rv   rw   DescribeGroupsRequestDescribeGroupsResponsery   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   CreatePartitionsRequestCreatePartitionsResponser   r   r   r   DeleteGroupsRequestDeleteGroupsResponser   r   DescribeClientQuotasRequestDescribeClientQuotasResponser   r   "AlterPartitionReassignmentsRequest#AlterPartitionReassignmentsResponser   r   !ListPartitionReassignmentsRequest"ListPartitionReassignmentsResponser   r   r   r   r   ElectLeadersRequestElectLeadersResponser$   r$   r$   r%   <module>   s   @

	

