Dana Powers 48e96822b3 Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors

2016-01-24 13:25:28 -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

Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors

2016-01-24 13:25:28 -08:00

consumer.py

KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync

2016-01-10 12:06:04 -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