Skip to content

Commit ca7b7dc

Browse files
authored
MINOR fix typo; remove unused members (#1906)
1 parent 3f11b3b commit ca7b7dc

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

src/confluent_kafka/schema_registry/schema_registry_client.py

-2
Original file line numberDiff line numberDiff line change
@@ -351,8 +351,6 @@ class _SchemaCache(object):
351351

352352
def __init__(self):
353353
self.lock = Lock()
354-
self.schemaid_index = {}
355-
self.schema_index = {}
356354
self.schema_id_index = defaultdict(dict)
357355
self.schema_index = defaultdict(dict)
358356
self.rs_id_index = defaultdict(dict)

tests/schema_registry/test_json_serdes.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ def test_json_serialize_references():
219219
'bytesField': base64.b64encode(b'foobar').decode('utf-8'),
220220
}
221221
obj = {
222-
'refField': referenced
222+
'otherField': referenced
223223
}
224224
ref_schema = {
225225
"type": "object",

0 commit comments

Comments
 (0)