From 3d16f2ff5f75380c8a9fce846f35e92bb5bfb935 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Tue, 5 Apr 2016 13:04:24 -0700
Subject: KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)

---
 kafka/protocol/legacy.py | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

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

diff --git a/kafka/protocol/legacy.py b/kafka/protocol/legacy.py
index 2eddf3b..08d2d01 100644
--- a/kafka/protocol/legacy.py
+++ b/kafka/protocol/legacy.py
@@ -336,11 +336,7 @@ class KafkaProtocol(object):
             payloads: list of OffsetFetchRequestPayload
             from_kafka: bool, default False, set True for Kafka-committed offsets
         """
-        if from_kafka:
-            version = 1
-        else:
-            version = 0
-
+        version = 1 if from_kafka else 0
         return kafka.protocol.commit.OffsetFetchRequest[version](
             consumer_group=group,
             topics=[(
-- 
cgit v1.2.1