summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
authorJim Lim <jim@quixey.com>2013-09-27 14:02:10 -0700
committerJim Lim <jim@quixey.com>2013-10-04 14:49:44 -0700
commita6c99b287b1cf9c39068be74d72150808588dd43 (patch)
tree0c036a3d0691c6c7f69166bdc373fbe4e79b2705 /example.py
parentcfd9f86e60429d1f7af8bcac5849808354b8719e (diff)
downloadkafka-python-a6c99b287b1cf9c39068be74d72150808588dd43.tar.gz
make changes to be more fault tolerant: clean up connections, brokers, failed_messages
- add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions