code: def __init__(self, probs: Dict, ride_type: str):
      self.producer = Producer(**probs)
      self.ride_type = ride_type
  
file_path: data-engineering-zoomcamp/cohorts/2023/week_6_stream_processing/producer_confluent.py
imports: from confluent_kafka import Producer
  import argparse
  import csv
  from typing import Dict
  from time import sleep
  from settings import CONFLUENT_CLOUD_CONFIG, GREEN_TAXI_TOPIC, FHV_TAXI_TOPIC, GREEN_TRIP_DATA_PATH, FHV_TRIP_DATA_PATH
label_desc: Use image node_id 1 to create a new RideCSVProducer object  with example: obj = RideCSVProducer(probs, ride_type)