o
    `j                     @   s   d dl mZ G dd dZdS )    )MemberToRemovec                   @   s,   e Zd ZdZdZedd Zedd ZdS )RemoveGroupMemberszremove-membersz$Remove members from a consumer groupc              	   C   sj   |j ddtdd |j ddtddg d	d
 |j ddtddg dd
 |j dtd dd |j dtd dd d S )Nz-gz
--group-idT)typerequiredz-mz--member-idappend
member_idsz)Dynamic member id to remove (repeatable).)r   actiondestdefaulthelpz-iz--group-instance-idgroup_instance_idszPStatic group.instance.id to remove (repeatable; requires broker LeaveGroup v3+).z--reasonzTOptional reason; sent to broker on LeaveGroup v5+ (KIP-800). Applied to all members.)r   r
   r   z--group-coordinator-idz<Send directly to this broker id, skipping coordinator lookup)add_argumentstrint)clsparser r   c/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/groups/remove_members.pyadd_arguments   s&   
z RemoveGroupMembers.add_argumentsc                    s`    fdd j D }| fdd jD  |std|j j| jd}dd | D S )	Nc                    s   g | ]	}t | jd qS ))	member_idreasonr   r   ).0midargsr   r   
<listcomp>   s    z.RemoveGroupMembers.command.<locals>.<listcomp>c                 3   s    | ]
}t | jd V  qdS ))group_instance_idr   Nr   )r   gidr   r   r   	<genexpr>    s    z-RemoveGroupMembers.command.<locals>.<genexpr>z<At least one --member-id or --group-instance-id is required.)group_coordinator_idc                 S   s   i | ]\}}||j qS r   )__name__)r   merrr   r   r   
<dictcomp>(   s    z.RemoveGroupMembers.command.<locals>.<dictcomp>)r   extendr   
ValueErrorremove_group_membersgroup_idr    items)r   clientr   membersresultr   r   r   command   s   
zRemoveGroupMembers.commandN)r!   
__module____qualname__COMMANDHELPclassmethodr   r-   r   r   r   r   r      s    
r   N)kafka.adminr   r   r   r   r   r   <module>   s    