From a57ab55a5c593c099453f988dc12a1ee3552ecc3 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Mon, 21 Dec 2015 01:44:53 -0800
Subject: Add OffsetResetStrategy enum class to kafka.protocol.offset

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

(limited to 'kafka/protocol')

diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py
index 776de39..606f1f1 100644
--- a/kafka/protocol/offset.py
+++ b/kafka/protocol/offset.py
@@ -1,6 +1,11 @@
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
+class OffsetResetStrategy(object):
+    LATEST = -1
+    EARLIEST = -2
+    NONE = 0
+
 
 class OffsetResponse(Struct):
     SCHEMA = Schema(
-- 
cgit v1.2.1