From c9bff0701ea153933dee8c03cf8feb3470e39c52 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 22 May 2016 11:35:26 -0700 Subject: Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) --- 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