Dana Powers 8303780259 Check for None returned from least_loaded_node when no brokers are available

2016-03-13 23:49:55 -07:00

..

assignors

Add RangePartitionAssignor (and use as default); add assignor tests

2016-02-16 12:41:00 -08:00

__init__.py

AbstractCoordinator (modelled after upstream Java class)

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

base.py

Log successful heartbeat as INFO; improve heartbeat response logging

2016-03-12 15:08:36 -08:00

consumer.py

Check for None returned from least_loaded_node when no brokers are available

2016-03-13 23:49:55 -07:00

heartbeat.py

Fixup heartbeat config assertion

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

protocol.py

Add RangePartitionAssignor (and use as default); add assignor tests

2016-02-16 12:41:00 -08:00