summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #129 from wizzat/kafka-0.8.0-releasekafka-0.8.0-releaseDana Powers2014-03-214-1/+18
|\ | | | | Kafka 0.8.0 release version fixups
| * Add more reprMark Roberts2014-02-241-1/+4
| |
| * Add SimpleProducer reprMark Roberts2014-02-241-0/+3
| |
| * Add consumer reprMark Roberts2014-02-241-0/+8
| |
| * Add repr to clientMark Roberts2014-02-241-0/+3
| |
| * Correct __version__ in initMark Roberts2014-02-241-1/+1
|/
* Update kafka-src to 0.8.0 tagDavid Arthur2013-12-061-0/+0
|
* Set host and port in ExternalService test fixtureDavid Arthur2013-11-111-0/+2
| | | | | So we can run tests against an already running Kafka instance KAFKA_URI=tcp://localhost:9092 python -m test.test_integration
* Merge pull request #62 from mahendra/cons-windowsMahendra M2013-10-091-53/+63
|\ | | | | Ensure that multiprocess consumer works in windows
| * Ensure that multiprocess consumer works in windowsMahendra M2013-10-081-53/+63
|/
* Merge pull request #61 from mahendra/prod-windowsMahendra M2013-10-073-51/+87
|\ | | | | Ensure that async producer works in windows. Fixes #46
| * Merge branch 'master' into prod-windowsMahendra M2013-10-087-30/+173
| |\ | |/ |/| | | | | Conflicts: kafka/producer.py
* | Merge pull request #55 from quixey/fault-toleranceDavid Arthur2013-10-077-30/+173
|\ \ | | | | | | | | | | | | Improve fault tolerance by handling leadership election and other metadata changes Thanks, @jimjh!
| * | make changes to be more fault tolerant: clean up connections, brokers, ↵Jim Lim2013-10-047-30/+173
|/ / | | | | | | | | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception
| * Ensure that async producer works in windows. Fixes #46Mahendra M2013-10-073-51/+87
|/ | | | | | | | | | | | | | | As per the multiprocessing module's documentation, the objects passed to the Process() class must be pickle-able in Windows. So, the Async producer did not work in windows. To fix this we have to ensure that code which uses multiprocessing has to follow certain rules * The target=func should not be a member function * We cannot pass objects like socket() to multiprocessing This ticket fixes these issues. For KafkaClient and KafkaConnection objects, we make copies of the object and reinit() them inside the child processes.
* Merge pull request #59 from mrtheb/masterDavid Arthur2013-10-047-82/+100
|\ | | | | flake8 (pep8 and pyflakes) clean-up
| * Test fixes after flake8 runmrtheb2013-10-032-3/+4
| |
| * flake8 pass (pep8 and pyflakes)mrtheb2013-10-036-80/+97
|/
* Update kafka-src to 0.8.0 RC1David Arthur2013-10-031-0/+0
| | | | resolves #58
* remove unused exception instance variablesVetoshkin Nikita2013-10-032-2/+2
|
* use NotImplementedError instead of NotImplementedErrorVetoshkin Nikita2013-10-031-1/+1
|
* don't forget to call superclass __init__Vetoshkin Nikita2013-10-032-1/+3
|
* style: fix camelCase variable names againVetoshkin Nikita2013-10-031-2/+2
|
* style: remove extra brackets one more timeVetoshkin Nikita2013-10-031-5/+5
|
* style: remove extra bracketsVetoshkin Nikita2013-10-031-1/+1
|
* style: fix camelCase variable names once moreVetoshkin Nikita2013-10-031-3/+3
|
* style: fix camelCase variable namesVetoshkin Nikita2013-10-034-30/+29
| | | | | | Conflicts: kafka/util.py
* style: use triple quotes for docstringsVetoshkin Nikita2013-10-032-4/+12
|
* style: fix whitespacesVetoshkin Nikita2013-10-033-1/+7
|
* Updating year in LICENSEDavid Arthur2013-10-031-1/+1
| | | [skip ci]
* Remove Python 2.6 from CI builds, ref #57David Arthur2013-10-031-1/+0
|
* Revert "Disable unit tests for 2.6, close #57"David Arthur2013-10-032-6/+1
| | | | This reverts commit e39e05f8a50b7528a22fed99dc67d561cbd79c41.
* Disable unit tests for 2.6, close #57David Arthur2013-10-032-1/+6
|
* Travis-CI workaround for multiprocessing.Queue OSErrorDavid Arthur2013-10-031-1/+4
| | | See https://github.com/travis-ci/travis-cookbooks/issues/155 for background
* Add assembly-package-dependency to Travis configDavid Arthur2013-10-031-2/+1
|
* Cherry-pick mrtheb/kafka-python 2b016b69mrtheb2013-10-032-4/+8
| | | | Set FetchRequest MaxBytes value to bufsize instead of fetchsize (=MinBytes)
* Cherry-pick mrtheb/kafka-python 8b9c7e51mrtheb2013-10-035-28/+32
| | | | | | | | | Sync tests and fixtures with kafka 0.8.0-beta1 tag Conflicts: README.md kafka-src
* Updating authors, thanks to all the contributors!David Arthur2013-10-021-0/+2
| | | Also testing out this -> [skip ci]
* Update POWERED-BY.mdDavid Arthur2013-10-021-1/+1
| | | Apparently GitHub flavored markdown doesn't fully work in md files? (@mumrah didn't auto-link)
* Adding a POWERED-BY.md file to people to give us propsDavid Arthur2013-10-021-0/+6
|
* Merge pull request #54 from jimjh/patch-1David Arthur2013-10-021-1/+1
|\ | | | | update README.md to link to travis-ci's build page
| * update README.md to link to travis-ci's build pageJim Lim2013-10-021-1/+1
|/
* Adding git-submodule update to Travis YML fileDavid Arthur2013-10-021-0/+1
| | | Hopefully this commit will trigger a build on TravisCI
* Merge pull request #53 from jimjh/testingDavid Arthur2013-10-022-1/+21
|\ | | | | Enable continuous integration with travis-ci.
| * add .travis.ymlJim Lim2013-10-012-1/+21
|/
* Merge pull request #49 from jimjh/import-buffer-underflow-errorDavid Arthur2013-09-271-0/+2
|\ | | | | import bufferunderflow error
| * import bufferunderflow errorJim Lim2013-09-271-0/+2
|/
* Merge pull request #48 from StevenLeRoux/masterDavid Arthur2013-09-261-2/+5
|\ | | | | Update README.md
| * Update README.mdSteven Le Roux2013-09-261-2/+5
| | | | | | Small fixes in ## Multiprocess consumer example.
* | Merge pull request #47 from StevenLeRoux/masterMahendra M2013-09-261-1/+1
|\ \ | |/ | | Update README.md
View Lorry Controller Status