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/structs.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'kafka/structs.py')

diff --git a/kafka/structs.py b/kafka/structs.py
index 48321e7..62f36dd 100644
--- a/kafka/structs.py
+++ b/kafka/structs.py
@@ -74,6 +74,9 @@ PartitionMetadata = namedtuple("PartitionMetadata",
 OffsetAndMetadata = namedtuple("OffsetAndMetadata",
     ["offset", "metadata"])
 
+OffsetAndTimestamp = namedtuple("OffsetAndTimestamp",
+    ["offset", "timestamp"])
+
 
 # Deprecated structs
 OffsetAndMessage = namedtuple("OffsetAndMessage",
-- 
cgit v1.2.1