summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
| * | 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
| | | | | | | | | | | | | | | | | | separate send / recv in BrokerConnection improve connection and error handling use different read and write fds for py3
| * | 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 ↵Dana Powers2015-12-041-2/+4
| | | | | | | | | | | | support tell()
| * | 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 ↵Dana Powers2015-12-042-3/+9
| | | | | | | | | | | | encoding spec
| * | 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 ↵Dana Powers2015-12-181-0/+6
| | | | | | | | | | | | installing server artifacts
* | | 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 docblock
| * | | Fix typo in docblockMatthias Endler2015-12-181-1/+1
|/ / /
* | | Merge pull request #489 from dpkp/producer_new_topicDana Powers2015-12-173-20/+18
|\ \ \ | | | | | | | | Handle new topic auto-creation in SimpleProducer.send_messages
| * | | 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 ↵Dana Powers2015-12-161-1/+1
| | | | | | | | | | | | | | | | SimpleProducer.send_messages call
| * | | 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 (> >= < <= ! =)
| * | | 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
| |
* | Include README.rst, CHANGES.md, and AUTHORS.md in manifestDana Powers2015-12-061-0/+3
| |
* | Update README linksDana Powers2015-12-061-7/+8
| |
* | Update README for new releaseDana Powers2015-12-061-8/+14
| |
* | Add KafkaConsumer.close() PR to CHANGESDana Powers2015-12-061-0/+1
| |
* | Merge pull request #426 from ucarion/ucarion-kafkaconsumer-closeDana Powers2015-12-061-0/+4
|\ \ | | | | | | Add KafkaConsumer#close
| * | Add KafkaConsumer#closeUlysse Carion2015-07-071-0/+4
| | |
* | | Update Changelog in preparation for 0.9.5 releaseDana Powers2015-12-061-0/+37
| | |
* | | Log deprecation warning for timeout argument in Producer.stop()Dana Powers2015-12-061-3/+7
| | |
* | | Merge pull request #485 from dpkp/async_producer_stopDana Powers2015-12-053-16/+15
|\ \ \ | | | | | | | | Producer.stop() should block until async thread completes
| * | | Producer.stop() now blocks until async thread completes (drop confusing ↵async_producer_stopDana Powers2015-12-051-7/+12
| | | | | | | | | | | | | | | | timeout arg)
| * | | Revert broken send_produce_request try/except from PR 467 (resps=None)Dana Powers2015-12-051-5/+1
| | | |
| * | | Use producer.stop() to flush messages in async producer testDana Powers2015-12-051-4/+2
|/ / /
* | | Fix requestId handling in send_broker_aware_requestDana Powers2015-12-041-2/+2
| | |
View Lorry Controller Status