diff --git a/src/confluent_kafka/schema_registry/schema_registry_client.py b/src/confluent_kafka/schema_registry/schema_registry_client.py index f04790a98..24da93e00 100644 --- a/src/confluent_kafka/schema_registry/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/schema_registry_client.py @@ -351,8 +351,6 @@ class _SchemaCache(object): def __init__(self): self.lock = Lock() - self.schemaid_index = {} - self.schema_index = {} self.schema_id_index = defaultdict(dict) self.schema_index = defaultdict(dict) self.rs_id_index = defaultdict(dict) diff --git a/tests/schema_registry/test_json_serdes.py b/tests/schema_registry/test_json_serdes.py index d05580198..5f6226af3 100644 --- a/tests/schema_registry/test_json_serdes.py +++ b/tests/schema_registry/test_json_serdes.py @@ -219,7 +219,7 @@ def test_json_serialize_references(): 'bytesField': base64.b64encode(b'foobar').decode('utf-8'), } obj = { - 'refField': referenced + 'otherField': referenced } ref_schema = { "type": "object",