diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-12 19:57:36 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-13 11:16:18 -0700 |
| commit | 894cfec656e44f92766775baf84cfd1d2e257901 (patch) | |
| tree | 541b9074d0ea4aa67dc5f64904f7ebd3f44c2549 /kafka/protocol/offset.py | |
| parent | 899f11730db5f209c03cfad20111ec131ee4c70b (diff) | |
| download | kafka-python-request_response_classes.tar.gz | |
Derive all api classes from Request / Response base classesrequest_response_classes
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 |