diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-20 19:19:08 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-20 19:19:08 +0530 |
| commit | e690b75590837f24d456bb5e5c766dac8ac093ad (patch) | |
| tree | 14e626c39d97a502835fcda0becae94375364531 /kafka/__init__.py | |
| parent | 612dea17c3fca1cb9283c6c60f6def7e76710d4c (diff) | |
| download | kafka-python-e690b75590837f24d456bb5e5c766dac8ac093ad.tar.gz | |
Make the default case as 'ack on local write'
Also, ensure that the case of 'no-acks' works fine
In conn.send(), do not wait for the response. Wait for it only on
conn.recv(). This behaviour is fine now since the connection is not
shared among consumer threads etc.
Diffstat (limited to 'kafka/__init__.py')
0 files changed, 0 insertions, 0 deletions