This is probably a better fit for the pykafka issue tracker. AFAIK, there's no public kafka API for creating partitions right now, so pykafka is likely hacking around this by calling out to internal Java APIs, so it will be brittle
On Thu, Feb 23, 2017 at 5:13 AM, VIVEK KUMAR MISHRA 13BIT0066 < vivekkumar.mishra2...@vit.ac.in> wrote: > Hi All, > > I am trying to create partitions automatically using python script instead > of doing the same through terminal. > > I am using partition class of pykafka package to do so and > kafka_2.11-0.9.0.0,but I am not getting the desired output, only one > partition is getting created. > Please do suggest me any solution through which I can do this using > python. > > Thank You! > > Regards, > Vivek Mishra >