From 96530f6a9c4a31d23b069ba162dba6cf45a5efd0 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 22 May 2016 12:41:17 -0700 Subject: Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) --- kafka/errors.py | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'kafka/errors.py') diff --git a/kafka/errors.py b/kafka/errors.py index dd64b04..a34ffef 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -310,6 +310,12 @@ class ClusterAuthorizationFailedError(BrokerResponseError): ' use an inter-broker or administrative API.') +class InvalidTimestampError(BrokerResponseError): + errno = 32 + message = 'INVALID_TIMESTAMP' + description = ('The timestamp of the message is out of acceptable range.') + + class KafkaUnavailableError(KafkaError): pass -- cgit v1.2.1