code: def __init__(self, props: Dict):
      self.consumer = KafkaConsumer(**props)
  
imports: import argparse
  from typing import Dict, List
  from kafka import KafkaConsumer
  from settings import BOOTSTRAP_SERVERS, CONSUME_TOPIC_RIDES_CSV
label_desc: Use image node_id 1 to create a new RideCSVConsumer object  with example: obj = RideCSVConsumer(props)