Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Added controlled thread shutdown to example.py (#1268) | Benn Roth | 2017-10-21 | 1 | -8/+32 |
| | |||||
* | Describe consumer thread-safety | Linus Wallgren | 2017-06-16 | 1 | -3/+4 |
| | |||||
* | Use KafkaProducer / KafkaConsumer in example.py | Dana Powers | 2016-02-15 | 1 | -13/+12 |
| | |||||
* | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-02-26 | 1 | -2/+2 |
|\ | | | | | | | | | Conflicts: example.py | ||||
| * | Allow KafkaClient to take in a list of brokers for bootstrapping | Marc Labbe | 2013-11-14 | 1 | -1/+1 |
| | | |||||
* | | Update logging config to include timestamps for better/easier debugging | Mark Roberts | 2014-02-25 | 1 | -1/+4 |
| | | |||||
* | | Update example.py to compile, add friendly load_example.py | Mark Roberts | 2014-02-25 | 1 | -13/+35 |
|/ | |||||
* | Typo in example.py | David Arthur | 2013-04-02 | 1 | -1/+1 |
| | |||||
* | Refactoring a bit, cleanup for 0.8 | David Arthur | 2013-04-02 | 1 | -16/+10 |
| | | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1) | ||||
* | Big code re-org | David Arthur | 2013-04-02 | 1 | -5/+3 |
| | |||||
* | Renaming kafka.py to client.py | David Arthur | 2012-10-02 | 1 | -2/+1 |
| | |||||
* | Adding some integration tests | David Arthur | 2012-09-28 | 1 | -1/+1 |
| | |||||
* | Starting on unit tests | David Arthur | 2012-09-27 | 1 | -2/+2 |
| | | | | | Updated several methods in KafkaClient to be classmethods. Updated some inline documentation also | ||||
* | Adding initial support for gzip compression | David Arthur | 2012-09-26 | 1 | -8/+11 |
| | |||||
* | Setting up a stand-alone repository for this | David Arthur | 2012-09-24 | 1 | -0/+29 |