The Confluent python client does not support this today. If you find a python api that does create topic partitions don't expect it to work with a secure Kafka cluster and expect it to have to be completely re-written in the near future when the new Kafka Admin API is implemented under the covers.
-hans /** * Hans Jespersen, Principal Systems Engineer, Confluent Inc. * h...@confluent.io (650)924-2670 */ On Sun, Feb 26, 2017 at 5:44 PM, VIVEK KUMAR MISHRA 13BIT0066 < vivekkumar.mishra2...@vit.ac.in> wrote: > My question is can we create partitions in topic using any pythonic API? > > On Sun, Feb 26, 2017 at 8:24 PM, Hans Jespersen <h...@confluent.io> wrote: > > > The current Java AdminUtils are older code that talks to zookeeper and > > does not support a secured Kafka cluster. > > There will be a new Java Admin API in the future that talks to the Kafka > > brokers directly using the admin extensions to the Kafka protocol which > are > > already in the 0.10.2 brokers. > > I would expect that once there is a reference implementation of the new > > Java Admin client that other client libraries would implement similar > > interfaces. > > In the meantime I’m afraid we just need to use the existing Java admin > > utils or the CLI tools for just a little while longer. > > > > -hans > > > > > > > > > > > On Feb 26, 2017, at 2:42 PM, VIVEK KUMAR MISHRA 13BIT0066 < > > vivekkumar.mishra2...@vit.ac.in> wrote: > > > > > > Hi All, > > > > > > In kafka java driver, we have kafka.admin.AdminUtils class which has > > > methods like createTopic and addPartitions(). Do we have these type of > > > class and methods in any of kafka python drivers.If there is please do > > > suggest. > > > > > > Thank you . > > > > >
