o
    `j                     @   s   d dl Z G dd dZdS )    Nc                   @   s,   e Zd ZdZdZedd Zedd ZdS )DeleteTopicdeletezDelete Kafka Topicc              	   C   s2   |j ddtddg dd |j dtddg d	d d S )
Nz-tz--topicappendtopicsz
topic name)typeactiondestdefaulthelpz--id	topic_idsz
topic UUID)add_argumentstr)clsparser r   [/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/topics/delete.pyadd_arguments   s   zDeleteTopic.add_argumentsc                 C   s8   |j s
|js
tddd |jD }|j }||| S )Nz+At least one topic or topic_id is required!c                 S   s   g | ]}t |qS r   )uuidUUID).0topic_idr   r   r   
<listcomp>   s    z'DeleteTopic.command.<locals>.<listcomp>)r   r   
ValueErrordelete_topics)r   clientargsr   topic_namesr   r   r   command   s
   zDeleteTopic.commandN)__name__
__module____qualname__COMMANDHELPclassmethodr   r   r   r   r   r   r      s    
r   )r   r   r   r   r   r   <module>   s    