ó
    ‹ø9hO  ã                   ó$   • S SK Jr   " S S5      rg)é    )ÚIllegalArgumentErrorc                   ó&   • \ rS rSrSr  SS jrSrg)ÚNewTopicé   aë  A class for new topic creation
Arguments:
    name (string): name of the topic
    num_partitions (int): number of partitions
        or -1 if replica_assignment has been specified
    replication_factor (int): replication factor or -1 if
        replica assignment is specified
    replica_assignment (dict of int: [int]): A mapping containing
        partition id and replicas to assign to it.
    topic_configs (dict of str: str): A mapping of config key
        and value for the topic.
Nc                 ó´   • US:H  =(       d    US:H  US L -  (       d  [        S5      eXl        X l        X0l        U=(       d    0 U l        U=(       d    0 U l        g )NéÿÿÿÿzPeither num_partitions/replication_factor or replica_assignment must be specified)r   ÚnameÚnum_partitionsÚreplication_factorÚreplica_assignmentsÚtopic_configs)Úselfr	   r
   r   r   r   s         Ú]C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/admin/new_topic.pyÚ__init__ÚNewTopic.__init__   se   € ð ˜rÑ!×=Ð%7¸2Ñ%=Ø" dÐ*÷,ô 'ð$óð ð Œ	Ø,ÔØ"4ÔØ#6×#<¸"ˆÔ Ø*×0¨bˆÕó    )r	   r
   r   r   r   )NN)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   Ú__static_attributes__© r   r   r   r      s   † ñð$ !Ø÷1r   r   N)Úaiokafka.errorsr   r   r   r   r   Ú<module>r      s   ðÝ 0÷"1ò "1r   