We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c605e0c commit 53dc740Copy full SHA for 53dc740
kafka/protocol/types.py
@@ -194,9 +194,10 @@ def __init__(self, *array_of):
194
def encode(self, items):
195
if items is None:
196
return Int32.encode(-1)
197
+ encoded_items = [self.array_of.encode(item) for item in items]
198
return b''.join(
- [Int32.encode(len(items))] +
199
- [self.array_of.encode(item) for item in items]
+ [Int32.encode(len(encoded_items))] +
200
+ encoded_items
201
)
202
203
def decode(self, data):
0 commit comments