diff options
Diffstat (limited to 'kafka/protocol/types.py')
| -rw-r--r-- | kafka/protocol/types.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index ade1bc6..2fde24f 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -194,9 +194,10 @@ class Array(AbstractType): def encode(self, items): if items is None: return Int32.encode(-1) + encoded_items = [self.array_of.encode(item) for item in items] return b''.join( - [Int32.encode(len(items))] + - [self.array_of.encode(item) for item in items] + [Int32.encode(len(encoded_items))] + + encoded_items ) def decode(self, data): |