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 . > >