diff options
| author | Taras Voinarovskyi <voyn1991@gmail.com> | 2017-10-14 23:06:27 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-10-14 23:06:27 +0300 |
| commit | fbbd6ca5d999a8520d483ecfe0ad6f805eb8833f (patch) | |
| tree | 52e5860b1f8738b15e7c757c205961b761badd2b /kafka/protocol/produce.py | |
| parent | dd8e33654f2270097d6c1373dc272153670e48f8 (diff) | |
| parent | 365cae02da59721df77923bb5f5a2d94a84b2e83 (diff) | |
| download | kafka-python-fbbd6ca5d999a8520d483ecfe0ad6f805eb8833f.tar.gz | |
Merge pull request #1252 from dpkp/legacy_records_refactor
Refactor MessageSet and Message into LegacyRecordBatch
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): |