o `j@sGdddZdS)c@s,eZdZdZdZeddZeddZdS) CreateTopiccreatezCreate a Kafka TopiccCs6|jddtdd|jdtdd|jdtdddS) Nz-tz--topicT)typerequiredz--num-partitions)rdefaultz--replication-factor) add_argumentstrint)clsparserr [/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/topics/create.py add_argumentsszCreateTopic.add_argumentscCs||j|j|jdiS)N)num_partitionsreplication_factor) create_topicstopicrr)r clientargsr r r command szCreateTopic.commandN)__name__ __module__ __qualname__COMMANDHELP classmethodrrr r r r rs rN)rr r r r s