Joe Keen 5aaf3df47a Partition rebalance broken in kafka-python 0.9.5 ...

Our partiton rebalance mechanism broke on the upgrade from kafka-python 0.9.2
to 0.9.5.  Rather than fiddling with the internals of the kafka consumer object
we're now reconstructing the consumer object after each rebalance and handing
it the specific partitions it needs to worry about.

Closes-bug: #1560178
Change-Id: I469ceb28538db1f36918f211eaea4fcfdaa17649

2016-03-21 17:05:58 -06:00

..

__init__.py

Added kafka interaction objects to monasca_common

2015-10-30 18:03:45 -06:00

consumer.py

Partition rebalance broken in kafka-python 0.9.5

2016-03-21 17:05:58 -06:00

producer.py

Convert partition key to str

2016-01-26 13:46:08 -07:00