summaryrefslogtreecommitdiff
path: root/kafka/coordinator/protocol.py
Commit message (Expand)AuthorAgeFilesLines
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
* Add RangePartitionAssignor (and use as default); add assignor testsrange_assignorDana Powers2016-02-161-1/+1
* Move ConsumerProtocol definition to kafka.coordinator.protocolDana Powers2016-01-101-0/+33