o
    `j                     @   s"   d dl mZmZ G dd dZdS )    )OffsetAndMetadataTopicPartitionc                   @   s,   e Zd ZdZdZedd Zedd ZdS )AlterGroupOffsetszalter-offsetsz,Alter 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-oz--offsetappendoffsetsz+TOPIC:PARTITION:OFFSET triple (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   b/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/groups/alter_offsets.pyadd_arguments   s   
zAlterGroupOffsets.add_argumentsc           	      C   sf   i }|j D ]}|dd\}}}tt|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-AlterGroupOffsets.command.<locals>.<dictcomp>)	r   rsplitr   r   r   alter_group_offsetsgroup_idr   items)	r   clientargsr   specr   r   offsetresultr   r   r   command   s   
zAlterGroupOffsets.commandN)r   
__module____qualname__COMMANDHELPclassmethodr   r)   r   r   r   r   r      s    

r   N)kafka.structsr   r   r   r   r   r   r   <module>   s    