time --> timestamp to match Java API (#969)

2017-02-03 10:07:01 -08:00
parent d7679681d8
commit 4c62fb9247
1 changed files with 1 additions and 1 deletions
--- 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