Dana,
thank you for comprehensive response.
It seems that we have to be 0.8 compatible.
We've already discovered pykafka and BalancedConsumer is our favorite choice,
but it might be that assigning partition explicitly suits our needs better.
20.01.2016, 19:58, "Dana Powers" :
> version 0.9.5
version 0.9.5 of kafka-python does not support coordinated consumer groups.
You can get this feature in the master branch on github (
https://github.com/dpkp/kafka-python) using kafka 0.9.0.0 brokers. I expect
to release the updates to pypi soon, but for now you'll have to install
from source.
Oth
Hello.
I am trying to create consumer using kafka_python-0.9.5.
I expect that several instances of the script
==
consumer = KafkaConsumer('some-topic',
auto_offset_reset='largest',
metadata_broker_list=['localhost:9092'],
