There is one partition class in pykafka package in partition.py .Could you please tell me how to use that class.
On Sun, Feb 26, 2017 at 11:44 PM, Hans Jespersen <h...@confluent.io> wrote: > 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 . > > > > > > > > >
