diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-11-29 23:53:23 +0800 |
|---|---|---|
| committer | Zack Dever <zack.dever@rd.io> | 2015-12-04 11:25:40 -0800 |
| commit | 389fa20423eb7c553298aab47d79bfec989c72e2 (patch) | |
| tree | f5c279d4d174c3f772cdd5576179037126563c50 /kafka/protocol/message.py | |
| parent | 51227eae4f71565cf7abae51a91a6c037f705076 (diff) | |
| download | kafka-python-389fa20423eb7c553298aab47d79bfec989c72e2.tar.gz | |
Recursive repr, display all field names and values for Structs
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index 4024a5c..4f84c43 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -1,6 +1,6 @@ from .struct import Struct from .types import ( - Int8, Int16, Int32, Int64, Bytes, String, Array, Schema, AbstractType + Int8, Int32, Int64, Bytes, Schema, AbstractType ) from ..util import crc32 @@ -67,3 +67,7 @@ class MessageSet(AbstractType): msg_size = items[-1][1] bytes_read += (8 + 4 + msg_size) return items + + @classmethod + def repr(cls, messages): + return '[' + ', '.join([cls.ITEM.repr(m) for m in messages]) + ']' |