diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-10 00:13:16 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-11 18:09:17 +0300 |
| commit | fbea5f04bccd28f3aa15a1711548b131504591ac (patch) | |
| tree | 1c8a0efe687c2ace72fa146b4f03e15def8e3a95 /kafka/protocol/produce.py | |
| parent | f04435c5ed97fef0975a77a8dc7bae7c284bba63 (diff) | |
| download | kafka-python-fbea5f04bccd28f3aa15a1711548b131504591ac.tar.gz | |
Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format
Diffstat (limited to 'kafka/protocol/produce.py')
| -rw-r--r-- | kafka/protocol/produce.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kafka/protocol/produce.py b/kafka/protocol/produce.py index da1f308..34ff949 100644 --- a/kafka/protocol/produce.py +++ b/kafka/protocol/produce.py @@ -1,8 +1,7 @@ from __future__ import absolute_import from .api import Request, Response -from .message import MessageSet -from .types import Int16, Int32, Int64, String, Array, Schema +from .types import Int16, Int32, Int64, String, Array, Schema, Bytes class ProduceResponse_v0(Response): @@ -64,7 +63,7 @@ class ProduceRequest_v0(Request): ('topic', String('utf-8')), ('partitions', Array( ('partition', Int32), - ('messages', MessageSet))))) + ('messages', Bytes))))) ) def expect_response(self): @@ -109,7 +108,7 @@ class ProduceRequest_v3(Request): ('topic', String('utf-8')), ('partitions', Array( ('partition', Int32), - ('messages', MessageSet))))) + ('messages', Bytes))))) ) def expect_response(self): |