code: def load_schema(schema_path: str):
      path = os.path.realpath(os.path.dirname(__file__))
      with open(f"{path}/{schema_path}") as f:
          schema_str = f.read()
      return schema_str
  
file_path: data-engineering-zoomcamp/06-streaming/python/avro_example/consumer.py
imports: import os
  from typing import Dict, List
  from confluent_kafka import Consumer
  from confluent_kafka.schema_registry import SchemaRegistryClient
  from confluent_kafka.schema_registry.avro import AvroDeserializer
  from confluent_kafka.serialization import SerializationContext, MessageField
  from ride_record_key import dict_to_ride_record_key
  from ride_record import dict_to_ride_record
  from settings import BOOTSTRAP_SERVERS, SCHEMA_REGISTRY_URL, RIDE_KEY_SCHEMA_PATH, RIDE_VALUE_SCHEMA_PATH, KAFKA_TOPIC
label_desc: Use image node_id 2 for calling the RideAvroConsumer obj's underlying member method code with example usage: obj.load_schema(schema_path) and returns: schema_str