Dana Powers a154d0471c Ok to sleep in blocking poll for metadata update

2016-01-25 16:31:37 -08:00

..

assignors

Move ConsumerProtocol definition to kafka.coordinator.protocol

2016-01-10 00:25:12 -08:00

__init__.py

AbstractCoordinator (modelled after upstream Java class)

2015-12-28 15:18:43 -08:00

base.py

Ok to sleep in blocking poll for metadata update

2016-01-25 16:31:37 -08:00

consumer.py

Disable offset commits and auto-partition-assignment when group_id is None

2016-01-24 18:38:26 -08:00

heartbeat.py

Fixup heartbeat config assertion

2015-12-31 11:20:01 -08:00

protocol.py

Move ConsumerProtocol definition to kafka.coordinator.protocol

2016-01-10 00:25:12 -08:00