summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge branch 'master' into 0.80.8David Arthur2013-04-025-53/+62
|\ | | | | | | | | | | | | | | | | | | | | Conflicts: README.md kafka-src kafka/client.py kafka/consumer.py kafka/protocol.py setup.py test/integration.py
| * A few fixes for offset APIs in 0.8.1David Arthur2013-04-022-3/+1
| |
| * Update README and setup.py with new versionDavid Arthur2013-04-022-44/+57
| |
| * Update kafka-src to latest trunk, enable 0.8.1 featuresDavid Arthur2013-04-024-5/+3
| |
| * Typo in example.pyDavid Arthur2013-04-021-1/+1
| |
| * Update kafka-src to latest 0.8David Arthur2013-04-024-5/+17
| | | | | | | | Fix a broken test (100k was too much to send in one batch)
| * Update README with new APIsDavid Arthur2013-04-021-94/+19
| |
| * Bring acks and timeout down to the clientDavid Arthur2013-04-023-10/+11
| |
| * Refactoring a bit, cleanup for 0.8David Arthur2013-04-028-183/+215
| | | | | | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
| * Big code re-orgDavid Arthur2013-04-0211-673/+868
| |
| * Some work on a simple consumerDavid Arthur2013-04-023-11/+91
| |
| * Started on a simple producer and consumerDavid Arthur2013-04-023-7/+84
| |
| * Removing __main__ stuff from client.pyDavid Arthur2013-04-021-66/+0
| |
| * Integration tests passingDavid Arthur2013-04-028-1384/+761
| |
| * Protocol and low-level client done, adding testsDavid Arthur2013-04-026-272/+396
| |
| * Fix a bunch of bugsDavid Arthur2013-04-022-65/+138
| |
| * First pass of cleanup/refactoringDavid Arthur2013-04-023-225/+487
| | | | | | | | Also added a bunch of docstrings
| * Starting work on 0.8 compatDavid Arthur2013-04-022-0/+562
| |
| * Adding client_fetch_size to queue interfaceDavid Arthur2013-04-022-3/+57
| | | | | | | | Also more docs
| * Fix some typos, closes #12David Arthur2013-01-261-2/+2
| |
| * Merge pull request #11 from anentropic/masterDavid Arthur2012-11-221-2/+2
| |\ | | | | | | fix docs: iter_messages doesn't (any longer?) take a FetchRequest
| | * fix docs: iter_messages doesn't (any longer?) take a FetchRequestanentropic2012-11-221-2/+2
| |/ | | | | ...it takes the same args and instantiates its own one
* | Typo in example.pyDavid Arthur2013-04-021-1/+1
| |
* | Update kafka-src to latest 0.8David Arthur2013-04-014-5/+17
| | | | | | | | Fix a broken test (100k was too much to send in one batch)
* | Update README with new APIsDavid Arthur2013-04-011-92/+21
| |
* | Bring acks and timeout down to the clientDavid Arthur2013-04-013-10/+11
| |
* | Refactoring a bit, cleanup for 0.8David Arthur2013-04-018-183/+215
| | | | | | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
* | Big code re-orgDavid Arthur2013-03-3011-673/+868
| |
* | Some work on a simple consumerDavid Arthur2013-03-193-11/+91
| |
* | Started on a simple producer and consumerDavid Arthur2013-03-083-7/+84
| |
* | Removing __main__ stuff from client.pyDavid Arthur2013-03-011-66/+0
| |
* | Integration tests passingDavid Arthur2013-03-018-1384/+761
| |
* | Protocol and low-level client done, adding testsDavid Arthur2013-02-226-272/+396
| |
* | Fix a bunch of bugsDavid Arthur2013-02-202-65/+138
| |
* | First pass of cleanup/refactoringDavid Arthur2013-02-203-225/+487
| | | | | | | | Also added a bunch of docstrings
* | Starting work on 0.8 compatDavid Arthur2013-02-132-0/+562
| |
* | Adding client_fetch_size to queue interfaceDavid Arthur2012-11-202-3/+57
|/ | | | Also more docs
* Add some docs and KafkaQueue configDavid Arthur2012-11-192-19/+48
| | | | Ref #8
* Add a Queue-like producer/consumerDavid Arthur2012-11-193-0/+148
| | | | | | | | | | | | | | | | | Creates a producer process and one consumer process per partition. Uses `multiprocessing.Queue` for communication between the parent process and the producer/consumers. ```python kafka = KafkaClient("localhost", 9092) q = KafkaQueue(kafka, client="test-queue", partitions=[0,1]) q.put("test") q.get() q.close() kafka.close() ``` Ref #8
* Update README.mdDavid Arthur2012-11-161-2/+4
|
* Add Snappy support0.1-alphaDavid Arthur2012-11-166-21/+144
| | | | Fixes #2
* Update LICENSE with author+yearDavid Arthur2012-11-161-2/+1
|
* Integration test writes to a file instead of stdoutDavid Arthur2012-10-301-5/+6
|
* Clean up imports in client, fixed #5David Arthur2012-10-301-3/+0
|
* Replace socket.send with socket.sendall, Fixes #6David Arthur2012-10-301-5/+5
|
* Adding a test for 10k messagesDavid Arthur2012-10-301-0/+10
|
* Merge pull request #4 from benfred/masterDavid Arthur2012-10-291-1/+1
|\ | | | | exception handling fix
| * error handling fixBen Frederickson2012-10-251-1/+1
|/
* Fixing install instructionsDavid Arthur2012-10-031-2/+3
|
* Adding link to KafkaDavid Arthur2012-10-031-0/+2
|
View Lorry Controller Status