diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2017-02-03 10:08:12 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-02-03 10:08:12 -0800 |
| commit | ff2a129bc6eb8520ea66f48bb77e6f39bb722684 (patch) | |
| tree | 3e99c66b78756061b109c25039f5f1ab7b97ba04 /kafka/protocol/commit.py | |
| parent | 4c62fb9247ade4fe988766baa8876c0e11ee1d47 (diff) | |
| download | kafka-python-ff2a129bc6eb8520ea66f48bb77e6f39bb722684.tar.gz | |
DRY-up the OffsetFetch structs (#964)
Diffstat (limited to 'kafka/protocol/commit.py')
| -rw-r--r-- | kafka/protocol/commit.py | 21 |
1 files changed, 4 insertions, 17 deletions
diff --git a/kafka/protocol/commit.py b/kafka/protocol/commit.py index 69201be..7891267 100644 --- a/kafka/protocol/commit.py +++ b/kafka/protocol/commit.py @@ -116,20 +116,12 @@ class OffsetFetchResponse_v0(Struct): class OffsetFetchResponse_v1(Struct): API_KEY = 9 API_VERSION = 1 - SCHEMA = Schema( - ('topics', Array( - ('topic', String('utf-8')), - ('partitions', Array( - ('partition', Int32), - ('offset', Int64), - ('metadata', String('utf-8')), - ('error_code', Int16))))) - ) + SCHEMA = OffsetFetchResponse_v0.SCHEMA class OffsetFetchRequest_v0(Struct): API_KEY = 9 - API_VERSION = 0 # zookeeper-backed storage + API_VERSION = 0 # zookeeper-backed storage RESPONSE_TYPE = OffsetFetchResponse_v0 SCHEMA = Schema( ('consumer_group', String('utf-8')), @@ -141,14 +133,9 @@ class OffsetFetchRequest_v0(Struct): class OffsetFetchRequest_v1(Struct): API_KEY = 9 - API_VERSION = 1 # kafka-backed storage + API_VERSION = 1 # kafka-backed storage RESPONSE_TYPE = OffsetFetchResponse_v1 - SCHEMA = Schema( - ('consumer_group', String('utf-8')), - ('topics', Array( - ('topic', String('utf-8')), - ('partitions', Array(Int32)))) - ) + SCHEMA = OffsetFetchRequest_v0.SCHEMA OffsetFetchRequest = [OffsetFetchRequest_v0, OffsetFetchRequest_v1] |