diff options
| author | Alex Eftimie <alex.eftimie@getyourguide.com> | 2018-02-19 15:21:32 +0100 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-02-20 22:12:07 -0800 |
| commit | f5a0e402dbd05eeaf96649e39d35524dd993d9ef (patch) | |
| tree | 60cb3d9e496bbd5baed7a277b1f102cd25d8b385 | |
| parent | f1f6908e43f28c53207c402bca3836447341d5da (diff) | |
| download | kafka-python-f5a0e402dbd05eeaf96649e39d35524dd993d9ef.tar.gz | |
Fix response schema
| -rw-r--r-- | kafka/protocol/admin.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index 775bcf0..40963ac 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -338,7 +338,8 @@ class CreatePartitionsResponse_v0(Response): API_KEY = 37 API_VERSION = 0 SCHEMA = Schema( - ('topic_error_codes', Array( + ('throttle_time_ms', Int32), + ('topic_errors', Array( ('topic', String('utf-8')), ('error_code', Int16), ('error_message', String('utf-8')))) |