Skip to content

Commit 107911d

Browse files
committed
Fix delete_subject ClientError format string
1 parent 63693b3 commit 107911d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

confluent_kafka/avro/cached_schema_registry_client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ def __init__(self, url, max_schemas_per_subject=1000, ca_location=None, cert_loc
9393

9494
self.url = url.rstrip('/')
9595

96-
self.max_schemas_per_subject = max_schemas_per_subject
9796
# subj => { schema => id }
9897
self.subject_to_schema_ids = defaultdict(dict)
9998
# id => avro_schema
@@ -105,6 +104,7 @@ def __init__(self, url, max_schemas_per_subject=1000, ca_location=None, cert_loc
105104
s.verify = conf.pop('ssl.ca.location', None)
106105
s.cert = self._configure_client_tls(conf)
107106
s.auth = self._configure_basic_auth(conf)
107+
108108
self.url = conf.pop('url')
109109

110110
self._session = s
@@ -239,7 +239,7 @@ def delete_subject(self, subject):
239239

240240
result, code = self._send_request(url, method="DELETE")
241241
if not (code >= 200 and code <= 299):
242-
raise ClientError('Unable to delete subject: %d' % result)
242+
raise ClientError('Unable to delete subject: {}'.format(result))
243243
return result
244244

245245
def get_by_id(self, schema_id):

0 commit comments

Comments
 (0)