diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2017-02-03 10:07:01 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-02-03 10:07:01 -0800 |
| commit | 4c62fb9247ade4fe988766baa8876c0e11ee1d47 (patch) | |
| tree | 24db2886e53695abad434ca6ffaca1c7b014e6e0 /kafka/protocol/offset.py | |
| parent | d7679681d8e4fff53aa4e7d9fc357ba07f8f65e4 (diff) | |
| download | kafka-python-4c62fb9247ade4fe988766baa8876c0e11ee1d47.tar.gz | |
time --> timestamp to match Java API (#969)
Diffstat (limited to 'kafka/protocol/offset.py')
| -rw-r--r-- | kafka/protocol/offset.py | 2 |
1 files changed, 1 insertions, 1 deletions
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 |