summaryrefslogtreecommitdiff
path: root/example.py
Commit message (Collapse)AuthorAgeFilesLines
* Update example.py (#2081)Mostafa-Elmenbawy2020-09-071-18/+28
| | | Co-authored-by: MostafaElmenabawy <momenabawy@synapse-analytics.io>
* Added controlled thread shutdown to example.py (#1268)Benn Roth2017-10-211-8/+32
|
* Describe consumer thread-safetyLinus Wallgren2017-06-161-3/+4
|
* Use KafkaProducer / KafkaConsumer in example.pyDana Powers2016-02-151-13/+12
|
* Merge branch 'master' into conn_refactorMark Roberts2014-02-261-2/+2
|\ | | | | | | | | Conflicts: example.py
| * Allow KafkaClient to take in a list of brokers for bootstrappingMarc Labbe2013-11-141-1/+1
| |
* | Update logging config to include timestamps for better/easier debuggingMark Roberts2014-02-251-1/+4
| |
* | Update example.py to compile, add friendly load_example.pyMark Roberts2014-02-251-13/+35
|/
* Typo in example.pyDavid Arthur2013-04-021-1/+1
|
* Refactoring a bit, cleanup for 0.8David Arthur2013-04-021-16/+10
| | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
* Big code re-orgDavid Arthur2013-04-021-5/+3
|
* Renaming kafka.py to client.pyDavid Arthur2012-10-021-2/+1
|
* Adding some integration testsDavid Arthur2012-09-281-1/+1
|
* Starting on unit testsDavid Arthur2012-09-271-2/+2
| | | | | Updated several methods in KafkaClient to be classmethods. Updated some inline documentation also
* Adding initial support for gzip compressionDavid Arthur2012-09-261-8/+11
|
* Setting up a stand-alone repository for thisDavid Arthur2012-09-241-0/+29