diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-11-23 10:17:59 -0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-01-03 13:46:47 -0800 |
| commit | 2e0ada055886ad01cc193b1007d3f79717b5c9df (patch) | |
| tree | 335b8f1c9a3c867a8b6590b26fac139c9980a01d /kafka/conn.py | |
| parent | 807ac8244cd39ca8426cfeda245ec27802c0a600 (diff) | |
| download | kafka-python-2e0ada055886ad01cc193b1007d3f79717b5c9df.tar.gz | |
Fix response error checking in KafkaAdminClient send_to_controller
Previously we weren't accounting for when the response tuple also has a
`error_message` value.
Note that in Java, the error fieldname is inconsistent:
- `CreateTopicsResponse` / `CreatePartitionsResponse` uses `topic_errors`
- `DeleteTopicsResponse` uses `topic_error_codes`
So this updates the `CreateTopicsResponse` classes to match.
The fix is a little brittle, but should suffice for now.
Diffstat (limited to 'kafka/conn.py')
0 files changed, 0 insertions, 0 deletions