From 4c62fb9247ade4fe988766baa8876c0e11ee1d47 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Fri, 3 Feb 2017 10:07:01 -0800 Subject: time --> timestamp to match Java API (#969) --- kafka/protocol/offset.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/protocol/offset.py') diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py index 77a6a09..5182d63 100644 --- a/kafka/protocol/offset.py +++ b/kafka/protocol/offset.py @@ -63,7 +63,7 @@ class OffsetRequest_v1(Struct): ('topic', String('utf-8')), ('partitions', Array( ('partition', Int32), - ('time', Int64))))) + ('timestamp', Int64))))) ) DEFAULTS = { 'replica_id': -1 -- cgit v1.2.1