delta/python-packages/kafka-python.git/kafka/partitioner/roundrobin.py, branch batch_size_zero github.com: mumrah/kafka-python.git make partitions arg optional in *Partitioner.partition, defaulting to self.partitions from init 2015-02-09T18:34:19+00:00 Dana Powers dana.powers@rd.io 2015-02-06T19:57:49+00:00 fb03c69544221a25e925b8c6af45e44ac6944b2a 






Separate consumers/producers/partitioners
2014-09-11T05:14:29+00:00

Dana Powers
dana.powers@rd.io

2014-09-09T23:42:23+00:00

27e812e66bd04d3acf59ad6792b07d1c7056c036