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/producer.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/producer.py')
| -rw-r--r-- | kafka/producer.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index 2412d6d..9ed0056 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -30,7 +30,7 @@ class Producer(object): DEFAULT_ACK_TIMEOUT = 1000 - def __init__(self, client, async=False, req_acks=ACK_NOT_REQUIRED, + def __init__(self, client, async=False, req_acks=ACK_AFTER_LOCAL_WRITE, ack_timeout=DEFAULT_ACK_TIMEOUT): self.client = client self.async = async @@ -86,7 +86,7 @@ class SimpleProducer(Producer): for an acknowledgement """ def __init__(self, client, topic, async=False, - req_acks=Producer.ACK_NOT_REQUIRED, + req_acks=Producer.ACK_AFTER_LOCAL_WRITE, ack_timeout=Producer.DEFAULT_ACK_TIMEOUT): self.topic = topic client._load_metadata_for_topics(topic) @@ -116,7 +116,7 @@ class KeyedProducer(Producer): for an acknowledgement """ def __init__(self, client, topic, partitioner=None, async=False, - req_acks=Producer.ACK_NOT_REQUIRED, + req_acks=Producer.ACK_AFTER_LOCAL_WRITE, ack_timeout=Producer.DEFAULT_ACK_TIMEOUT): self.topic = topic client._load_metadata_for_topics(topic) |