diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-14 13:34:37 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-14 13:34:37 -0700 |
| commit | 65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e (patch) | |
| tree | c5b7144b04c9238ae459d80339f27b6af33b5a5c /kafka/protocol/offset.py | |
| parent | a00f9ead161e8b05ac953b460950e42fa0e0b7d6 (diff) | |
| download | kafka-python-65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e.tar.gz | |
Derive all api classes from Request / Response base classes (#1030)
Diffstat (limited to 'kafka/protocol/offset.py')
| -rw-r--r-- | kafka/protocol/offset.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py index 5182d63..588dfec 100644 --- a/kafka/protocol/offset.py +++ b/kafka/protocol/offset.py @@ -1,6 +1,6 @@ from __future__ import absolute_import -from .struct import Struct +from .api import Request, Response from .types import Array, Int16, Int32, Int64, Schema, String @@ -10,7 +10,7 @@ class OffsetResetStrategy(object): NONE = 0 -class OffsetResponse_v0(Struct): +class OffsetResponse_v0(Response): API_KEY = 2 API_VERSION = 0 SCHEMA = Schema( @@ -22,7 +22,7 @@ class OffsetResponse_v0(Struct): ('offsets', Array(Int64)))))) ) -class OffsetResponse_v1(Struct): +class OffsetResponse_v1(Response): API_KEY = 2 API_VERSION = 1 SCHEMA = Schema( @@ -36,7 +36,7 @@ class OffsetResponse_v1(Struct): ) -class OffsetRequest_v0(Struct): +class OffsetRequest_v0(Request): API_KEY = 2 API_VERSION = 0 RESPONSE_TYPE = OffsetResponse_v0 @@ -53,7 +53,7 @@ class OffsetRequest_v0(Struct): 'replica_id': -1 } -class OffsetRequest_v1(Struct): +class OffsetRequest_v1(Request): API_KEY = 2 API_VERSION = 1 RESPONSE_TYPE = OffsetResponse_v1 |