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 .
