diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-25 15:04:55 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:47 +0300 |
| commit | b82f94f5a409a237222a6486a870751fa17da254 (patch) | |
| tree | e61e22baa87cf055cdb41d829f607989243c456f /kafka/common.py | |
| parent | 67424a22869b1906f7a02e2d895f68170f6d0f1d (diff) | |
| download | kafka-python-b82f94f5a409a237222a6486a870751fa17da254.tar.gz | |
Retries for async batching
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/kafka/common.py b/kafka/common.py index 8207bec..b3380d7 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -6,6 +6,7 @@ from collections import namedtuple # Structs # ############### +<<<<<<< HEAD # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-MetadataAPI MetadataRequest = namedtuple("MetadataRequest", ["topics"]) @@ -14,8 +15,15 @@ MetadataResponse = namedtuple("MetadataResponse", ["brokers", "topics"]) # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ProduceAPI -ProduceRequest = namedtuple("ProduceRequest", - ["topic", "partition", "messages"]) +_ProduceRequest = namedtuple("ProduceRequest", + ["topic", "partition", "messages", "retries"]) + + +class ProduceRequest(_ProduceRequest): + def __new__(cls, topic, partition, messages, retries=0): + return super(ProduceRequest, cls).__new__( + cls, topic, partition, messages, retries) + ProduceResponse = namedtuple("ProduceResponse", ["topic", "partition", "error", "offset"]) |