summaryrefslogtreecommitdiff
path: root/kafka/protocol/produce.py
Commit message (Expand)AuthorAgeFilesLines
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-9/+8
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-041-55/+26
* Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-041-0/+59