Dana Powers 3d4d98ed78 Merge pull request #389 from dpkp/task_done_key_error ...

KafkaConsumer.task_done: warn and skip unrecognized topic-partitions

2015-06-08 18:20:53 -07: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

Use separate module loggers instead of a single 'kafka' logger

2015-06-06 16:11:20 -07:00

kafka.py

KafkaConsumer.task_done - warn and skip messages from unrecognized topic-partitions

2015-06-06 10:25:36 -07:00

multiprocess.py

Merge pull request #380 from dpkp/multiprocess_consumer_partitions

2015-06-08 16:08:57 -07:00

simple.py

SimpleConsumer should refresh metadata and retry on leadership changes; only raise on UnknownTopicOrPartition

2015-06-08 16:12:01 -07:00