Re: Anouncing PyKafka!

gt; Another question, I can see AsyncProducer is not yet implemented, any idea > by when it can be available? > > Thanks, > Vijay > > On 10 June 2015 at 18:42, Keith Bourgoin wrote: > > > Hi Vijay, > > > > PyKafka support custom partitioners so that you can

Re: Anouncing PyKafka!

upport keyed Producer? > I mean how it works when I have multiple partitions? Will it be able to > identify partition based of the key which I pass? > > On 9 June 2015 at 00:54, Keith Bourgoin wrote: > > > Hi Kafka folks, > > > > I'm happy to announce the 1.

Anouncing PyKafka!

Hi Kafka folks, I'm happy to announce the 1.0 release of PyKafka , a new Python driver for Kafka! This is an upgrade of an older library, named samsa, which was only compatible with Kafka 0.7.x. We've spent the last few months upgrading it to work with Kafka 0.

Re: as i understand rebalance happens on client side

ate! Interestingly i've found your library > yesterday and was going to borrow your zookeeper code for partition > management. Do you have any ETA for the 0.8 support? > > Thanks! > > > On Thu, Oct 3, 2013 at 8:09 AM, Keith Bourgoin >wrote: > > > Hi Kane

Re: as i understand rebalance happens on client side

Hi Kane, I just wanted to chime in as well. I currently maintain samsa ( https://github.com/getsamsa/samsa or PyPI), which does implement the rebalancing logic, but currently doesn't support 0.8. If you're on 0.7.x still, it might be helpful. If not, we're working on 0.8 support, but it probably w