code: def read_records(resource_path: str):
      records = []
      with open(resource_path, "r") as f:
          reader = csv.reader(f)
          header = next(reader)  # skip the header row
          for row in reader:
              records.append(Ride(arr=row))
      return records
  
file_path: data-engineering-zoomcamp/06-streaming/python/json_example/producer.py
imports: import csv
  import json
  from typing import List, Dict
  from kafka import KafkaProducer
  from kafka.errors import KafkaTimeoutError
  from ride import Ride
  from settings import BOOTSTRAP_SERVERS, INPUT_DATA_PATH, KAFKA_TOPIC
label_desc: Use image node_id 2 for calling the JsonProducer obj's underlying member method code with example usage: obj.read_records(resource_path) and returns: records