o
    `j                     @   s   d dl mZ G dd dZdS )    )TopicPartitionc                   @   s,   e Zd ZdZdZedd Zedd ZdS )DeleteGroupOffsetszdelete-offsetsz-Delete committed offsets for a consumer groupc              
   C   sB   |j ddtdd |j ddtddg dd	d
 |j dtd dd d S )Nz-gz
--group-idT)typerequiredz-pz--partitionappend
partitionsz"TOPIC:PARTITION pair (repeatable).)r   actiondestdefaultr   helpz--group-coordinator-idz<Send directly to this broker id, skipping coordinator lookup)r   r
   r   )add_argumentstrint)clsparser r   c/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/groups/delete_offsets.pyadd_arguments   s   
z DeleteGroupOffsets.add_argumentsc                 C   sZ   g }|j D ]}|dd\}}|t|t| q|j|j||jd}dd | D S )N:   )group_coordinator_idc                 S   s$   i | ]\}}d |j |jf |jqS )z%s:%d)topic	partition__name__).0tperrr   r   r   
<dictcomp>   s    z.DeleteGroupOffsets.command.<locals>.<dictcomp>)	r   rsplitr   r   r   delete_group_offsetsgroup_idr   items)r   clientargsr   specr   r   resultr   r   r   command   s   
zDeleteGroupOffsets.commandN)r   
__module____qualname__COMMANDHELPclassmethodr   r&   r   r   r   r   r      s    

r   N)kafka.structsr   r   r   r   r   r   <module>   s    