Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1)produce_fetch_v2

1 files changed, 6 insertions, 0 deletions

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