diff options
Diffstat (limited to 'kafka/admin/client.py')
| -rw-r--r-- | kafka/admin/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/admin/client.py b/kafka/admin/client.py index e25afe7..4c780fb 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -334,7 +334,7 @@ class KafkaAdminClient(object): # DeleteTopicsResponse returns topic_error_codes rather than topic_errors for topic, error_code in getattr(response, "topic_errors", response.topic_error_codes): error_type = Errors.for_code(error_code) - if tries and isinstance(error_type, NotControllerError): + if tries and error_type is NotControllerError: # No need to inspect the rest of the errors for # non-retriable errors because NotControllerError should # either be thrown for all errors or no errors. |