From 39f0e50b9441609e9dce4e60a1ab2c3f16680476 Mon Sep 17 00:00:00 2001
From: Taras Voinarovskiy <voyn1991@gmail.com>
Date: Sun, 30 Jul 2017 15:42:27 +0000
Subject: Added basic support for offsets_for_times API. Still needs to group
 by nodes and send in parallel.

---
 kafka/protocol/offset.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'kafka/protocol/offset.py')

diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py
index 8353f8c..5179658 100644
--- a/kafka/protocol/offset.py
+++ b/kafka/protocol/offset.py
@@ -3,6 +3,8 @@ from __future__ import absolute_import
 from .api import Request, Response
 from .types import Array, Int8, Int16, Int32, Int64, Schema, String
 
+UNKNOWN_OFFSET = -1
+
 
 class OffsetResetStrategy(object):
     LATEST = -1
@@ -91,7 +93,7 @@ class OffsetRequest_v2(Request):
     RESPONSE_TYPE = OffsetResponse_v2
     SCHEMA = Schema(
         ('replica_id', Int32),
-        ('isolation_level', Int8),
+        ('isolation_level', Int8),  # <- added isolation_level
         ('topics', Array(
             ('topic', String('utf-8')),
             ('partitions', Array(
-- 
cgit v1.2.1