o
    `šj-  ã                   @  sT   d dl mZ ddlmZ d dlmZ dZG dd„ deƒZG dd	„ d	eƒZg d
¢Z	dS )é    )Úannotationsé   )ÚApiData©ÚTopicPartitionÚconsumerc                   @  s   e Zd ZdS )ÚConsumerProtocolSubscriptionN)Ú__name__Ú
__module__Ú__qualname__© r   r   ú^/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/consumer/metadata.pyr   
   s    r   c                   @  s4   e Zd Zeddd„ƒZejddd„ƒZdd	d
„ZdS )ÚConsumerProtocolAssignmentÚreturnÚlistc                 C  s   | j S ©N©Úassigned_partitions©Úselfr   r   r   Ú
assignment   s   z%ConsumerProtocolAssignment.assignmentÚvalueÚNonec                 C  s
   || _ d S r   r   )r   r   r   r   r   r      s   
úlist[TopicPartition]c                 C  s   dd„ | j D ƒS )Nc                 S  s$   g | ]\}}|D ]}t ||ƒ‘qqS r   r   )Ú.0ÚtopicÚ
partitionsÚ	partitionr   r   r   Ú
<listcomp>   s    þþz9ConsumerProtocolAssignment.partitions.<locals>.<listcomp>r   r   r   r   r   r      s   ÿz%ConsumerProtocolAssignment.partitionsN)r   r   )r   r   r   r   )r   r   )r	   r
   r   Úpropertyr   Úsetterr   r   r   r   r   r      s    r   )r   r   ÚConsumerProtocolTypeN)
Ú
__future__r   Úapi_datar   Úkafka.structsr   r!   r   r   Ú__all__r   r   r   r   Ú<module>   s    