Python API for the Kafka Message Queue
Stars
56
Forks
25
Watchers
56
Open Issues
6
Overall repository health assessment
No package.json found
This might not be a Node.js project
3
commits
2
commits
1
commits
1
commits
1
commits
1
commits
Make sure the Batch Producer timer can survive a fork
4a9d62cView on GitHubCatching IOError instead of integers and checking the errno on the IOError for the same error codes
5e782b2View on GitHubAdd offset parameter to Consumer class which allows user to consume from a previously saved spot
91c941aView on GitHubMerge pull request #11 from sholsapp/add-max-message-size
0d5af6bView on GitHubAllow clients to enforce a maximum produce message size. This allows producers
1aa1e34View on GitHubMerge pull request #10 from sholsapp/batch-producer-fixes
46ba940View on GitHubAdded a BatchProducer that uses a time interval to batch messages. Did some PEP8 formatting. Added a .gitignore file for Python. Added tests for kafka producers.
4bdc853View on GitHub