Dana Powers 89ea42af45 Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close ...

Add KafkaConsumer#close

2015-12-06 16:08:47 -08:00

..

__init__.py

Move KafkaConsumer to kafka.consumer.kafka module; make available for import from kafka at top-level

2014-12-15 12:42:56 -08:00

base.py

Merge pull request #456 from barricadeio/mp-retry

2015-12-02 13:45:54 -08:00

kafka.py

Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close

2015-12-06 16:08:47 -08:00

multiprocess.py

Fix python3 / python2 comments re queue/Queue

2015-12-02 15:00:35 -08:00

simple.py

new pylint disables for pylint 1.5.1

2015-12-02 17:43:15 -08:00