From 9c19ea7cbe163b0c434ce9dd9c8c42471027cce5 Mon Sep 17 00:00:00 2001
From: Taras Voinarovskyi <voyn1991@gmail.com>
Date: Tue, 7 Mar 2017 00:59:26 +0200
Subject: Added `max_bytes` option and FetchRequest_v3 usage. (#962)

* Added `max_bytes` option and FetchRequest_v3 usage.
* Add checks for versions above 0.10 based on ApiVersionResponse
---
 kafka/client_async.py | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'kafka/client_async.py')

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 85de90a..2913b43 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -156,6 +156,8 @@ class KafkaClient(object):
         'sasl_plain_password': None,
     }
     API_VERSIONS = [
+        (0, 10, 1),
+        (0, 10, 0),
         (0, 10),
         (0, 9),
         (0, 8, 2),
-- 
cgit v1.2.1