o
    `j                     @   s   G d d dZ dS )c                   @   s,   e Zd ZdZdZedd Zedd ZdS )DescribeTopicPartitionsdescribezADescribe topic partitions with pagination (KIP-966, broker >=3.9)c              
   C   sT   |j ddtddg ddd |j dtd	d
d |j dtd dd |j dtd dd d S )Nz-tz--topicappendtopicsTzTopic to describe (repeatable))typeactiondestdefaultrequiredhelpz--response-partition-limiti  zGMaximum number of partitions to include in the response (default: 2000))r   r   r
   z--cursor-topicz#Topic name to start pagination fromz--cursor-partitionz(Partition index to start pagination from)add_argumentstrint)clsparser r   a/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/partitions/describe.pyadd_arguments   s"   
z%DescribeTopicPartitions.add_argumentsc                 C   sV   d }|j d us|jd ur!|j d u s|jd u rtd|j |jd}|j|j|j|dS )Nz;--cursor-topic and --cursor-partition must be used together)
topic_namepartition_index)response_partition_limitcursor)cursor_topiccursor_partition
ValueErrordescribe_topic_partitionsr   r   )r   clientargsr   r   r   r   command   s   zDescribeTopicPartitions.commandN)__name__
__module____qualname__COMMANDHELPclassmethodr   r   r   r   r   r   r      s    
r   N)r   r   r   r   r   <module>   s    