diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-11-29 10:00:50 +0800 |
|---|---|---|
| committer | Zack Dever <zack.dever@rd.io> | 2015-12-04 11:25:40 -0800 |
| commit | 058567912e8d82c1da5e5ead9e30be532573a173 (patch) | |
| tree | eb5cdd9d7c25729441cfa097772ca0623e4cbfe0 /kafka/protocol/produce.py | |
| parent | a85e09df89a43de5b659a0fa4ed35bec37c60e04 (diff) | |
| download | kafka-python-058567912e8d82c1da5e5ead9e30be532573a173.tar.gz | |
Add simple BrokerConnection class; add request.RESPONSE_TYPE class vars
Diffstat (limited to 'kafka/protocol/produce.py')
| -rw-r--r-- | kafka/protocol/produce.py | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/kafka/protocol/produce.py b/kafka/protocol/produce.py index 532a702..ef2f96e 100644 --- a/kafka/protocol/produce.py +++ b/kafka/protocol/produce.py @@ -3,28 +3,27 @@ from .struct import Struct from .types import Int8, Int16, Int32, Int64, Bytes, String, Array, Schema -class ProduceRequest(Struct): - API_KEY = 0 - API_VERSION = 0 +class ProduceResponse(Struct): SCHEMA = Schema( - ('required_acks', Int16), - ('timeout', Int32), ('topics', Array( ('topic', String('utf-8')), ('partitions', Array( ('partition', Int32), - ('messages', MessageSet))))) + ('error_code', Int16), + ('offset', Int64))))) ) -class ProduceResponse(Struct): +class ProduceRequest(Struct): API_KEY = 0 API_VERSION = 0 + RESPONSE_TYPE = ProduceResponse SCHEMA = Schema( + ('required_acks', Int16), + ('timeout', Int32), ('topics', Array( ('topic', String('utf-8')), ('partitions', Array( ('partition', Int32), - ('error_code', Int16), - ('offset', Int64))))) + ('messages', MessageSet))))) ) |