diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-06 16:08:01 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 16:14:49 -0700 |
| commit | 868115c703afc4403adc8d9481bf31d2c15064dd (patch) | |
| tree | 335b0090cd382226b9b9f2edb39752b52b9c2234 /kafka/client.py | |
| parent | 3a4ceef3816e9ddfcb86099f691f72f1f60921cd (diff) | |
| download | kafka-python-868115c703afc4403adc8d9481bf31d2c15064dd.tar.gz | |
Raise an error if we attempt to group duplicate topic-partition payloads
- previously this would simply drop one of the payloads
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/client.py b/kafka/client.py index 7ea09d7..4302ce5 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -423,6 +423,8 @@ class KafkaClient(object): Arguments: payloads (list of ProduceRequest): produce requests to send to kafka + ProduceRequest payloads must not contain duplicates for any + topic-partition. acks (int, optional): how many acks the servers should receive from replica brokers before responding to the request. If it is 0, the server will not send any response. If it is 1, the server will wait |