summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * Refactor KafkaClient to use BrokerConnections and new Request/Response structsDana Powers2015-12-091-148/+131
| * Exception handling cleanup in BrokerConnection (also catch struct.errors in r...Dana Powers2015-12-091-4/+4
| * Add client_id and correlation_id to BrokerConnection constructor kwargsDana Powers2015-12-091-3/+7
| * Change KafkaProtocol to encode/decode Structs, not bytesDana Powers2015-12-092-252/+112
| * Support pickling of Structs -- _encode_self instance method needs some magicDana Powers2015-12-092-0/+26
| * Return PartialMessage object in MessageSet.decode if message is truncated by ...Dana Powers2015-12-091-3/+10
| * Fallback to simple repr() in Schema.repr()Dana Powers2015-12-091-7/+10
| * Fix BytesIO import in kafka.protocol.messageDana Powers2015-12-091-1/+3
| * Fix _mp_consume queue variable name conflictDana Powers2015-12-091-2/+2
| * Handle special __init__ signature in Message decode()Dana Powers2015-12-091-0/+8
| * Handle decoding partial messages in MessageSet - caused by FetchRequest max_b...Dana Powers2015-12-091-6/+24
| * Merge branch 'master' into 0.9Zack Dever2015-12-0722-62/+485
| |\
| * | few small cleanupsZack Dever2015-12-043-8/+2
| * | administration api schemasZack Dever2015-12-041-0/+44
| * | group membership api schemasZack Dever2015-12-041-0/+108
| * | Add size and correlation id decoding to try/except block in BrokerConnectionDana Powers2015-12-041-4/+5
| * | Add comment re bytes offset tracking in MessageSet decode()Dana Powers2015-12-041-1/+1
| * | Unfinished kafka.consumer.group commitDana Powers2015-12-041-0/+883
| * | Add simple Cluster class to manage broker metadataDana Powers2015-12-041-0/+91
| * | BrokerConnection:Dana Powers2015-12-041-11/+65
| * | Recursive repr, display all field names and values for StructsDana Powers2015-12-044-5/+27
| * | Use simply counting instead of buffer.tell() -- socket.makefile does not supp...Dana Powers2015-12-041-2/+4
| * | Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-046-58/+101
| * | Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-0410-371/+461
| * | Fix __init__ legacy relative module importDana Powers2015-12-041-1/+1
| * | Switch crc32 back to signed integer -- this is consistent with protocol encod...Dana Powers2015-12-042-3/+9
| * | Fix tests broken by legacy module moveDana Powers2015-12-042-3/+5
| * | Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-042-54/+59
| * | Basic 0.8 Request protocol classes, with encoding onlyDana Powers2015-12-041-0/+355
| * | Add base api type classes w/ encoders in kafka.protocol.typesDana Powers2015-12-041-0/+55
| * | Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-042-0/+6
* | | Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)simpleDana Powers2015-12-301-0/+2
* | | Remove old kafka-bin directory and verify kafka-run-class.sh exists when inst...Dana Powers2015-12-181-0/+6
* | | Only download/install server artifacts if bin/kafka-run-class.sh not foundDana Powers2015-12-181-5/+6
* | | Retry on FailedPayloadsError from consumer.pending() in failover testsDana Powers2015-12-181-4/+5
* | | Merge pull request #490 from mre/patch-1Dana Powers2015-12-181-1/+1
|\ \ \
| * | | Fix typo in docblockMatthias Endler2015-12-181-1/+1
|/ / /
* | | Merge pull request #489 from dpkp/producer_new_topicDana Powers2015-12-173-20/+18
|\ \ \
| * | | Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topicDana Powers2015-12-171-10/+11
| * | | Handle new topic creation / LeaderNotAvailableError in initial SimpleProducer...Dana Powers2015-12-161-1/+1
| * | | Add producer integration test for SimpleProducer handling new topic creationDana Powers2015-12-161-9/+6
|/ / /
* | | Merge pull request #487 from dpkp/kafka_version_testsDana Powers2015-12-105-56/+47
|\ \ \
| * | | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-105-56/+47
|/ / /
* | | Fix _mp_consume queue variable name conflictDana Powers2015-12-091-2/+2
* | | Bump version for development of next releaseDana Powers2015-12-091-1/+1
| |/ |/|
* | spelling fix in CHANGES.md and format fix in README.rstZack Dever2015-12-072-2/+2
* | Remove inadvertent markdown in CHANGES.mdDana Powers2015-12-071-1/+1
* | Release 0.9.5v0.9.5Dana Powers2015-12-072-2/+2
* | Update README links (restructured not markdown)Dana Powers2015-12-071-6/+5
* | Update docs for new releaseDana Powers2015-12-062-12/+20
View Lorry Controller Status