Dana Powers 584e5ec740 Attempt to clarify error message on consumer subscribe/assign assert failure

2016-03-14 18:25:20 -07:00

..

__init__.py

Switch to new KafkaConsumer in module imports

2016-01-03 16:14:37 -08:00

base.py

Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics

2016-03-13 09:35:49 -07:00

fetcher.py

Issue 545: Convert deserializer StopIteration errors to raw Exceptions

2016-02-15 12:31:18 -08:00

group.py

KafkaConsumer.poll should sleep to prevent tight-loops

2016-03-14 10:52:04 -07:00

multiprocess.py

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

2016-01-12 16:52:30 -08:00

simple.py

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

2016-01-12 16:52:30 -08:00

subscription_state.py

Attempt to clarify error message on consumer subscribe/assign assert failure

2016-03-14 18:25:20 -07:00