summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Making version number compatible with future versions0.7David Arthur2013-04-021-1/+1
|
* 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
* 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
|
* Updating kafka-src to 0.7.2David Arthur2012-10-032-1/+1
|
* Isn't it nice when tests actually find bugsDavid Arthur2012-10-022-6/+51
|
* Packaging improvmentsDavid Arthur2012-10-022-1/+40
| | | | | | | | | | | | | | | | | | | | | | | Can now: ```python import kafka kafka.KafkaClient("localhost", 9092) ``` or ```python from kafka.client import KafkaClient KafkaClient("localhost", 9092) ``` or ```python import kafka.client kafka.client.KafkaClient("localhost", 9092) ```
* Stupid markdownDavid Arthur2012-10-021-4/+4
|
* Fix tabs in README.mdDavid Arthur2012-10-021-30/+30
|
* Update README.md with install instructionsDavid Arthur2012-10-022-6/+25
|
* Renaming kafka.py to client.pyDavid Arthur2012-10-026-5/+9
|
* Moved codec stuff into it's own moduleDavid Arthur2012-10-025-24/+29
| | | | Snappy will go there when I get around to it
* Start work on packaging issue #3David Arthur2012-10-026-3/+16
|
* Integration test improvementsDavid Arthur2012-09-303-21/+53
| | | | | Call java directly instead of using start script. Fix synchronization problem with producing a message and it getting flushed.
* Update send_messages_simple example in README.mdDavid Arthur2012-09-281-4/+2
|
* Adding some integration testsDavid Arthur2012-09-283-8/+44
|
* Starting integration testsDavid Arthur2012-09-285-3/+269
|
* Adding simple (dumb) request testsDavid Arthur2012-09-272-2/+15
| | | | Integration tests to come
* Pointing kafka-src to 0.7.1-rc3David Arthur2012-09-271-0/+0
|
* Adding Kafka github mirror, pointing to 0.7.1-rc3David Arthur2012-09-272-0/+3
| | | | | | | To initialize submodules, run git submodule init git submodule update
* More unit testsDavid Arthur2012-09-272-2/+70
| | | | | | Run like: python -m unittest -v test
* Starting on unit testsDavid Arthur2012-09-273-40/+156
| | | | | Updated several methods in KafkaClient to be classmethods. Updated some inline documentation also
* Adding initial support for gzip compressionDavid Arthur2012-09-264-72/+163
|
* Adding Python syntax highlighting to README.mdDavid Arthur2012-09-241-2/+14
|
* Setting up a stand-alone repository for thisDavid Arthur2012-09-244-0/+782
View Lorry Controller Status