INPUT_DATA_PATH = '../resources/rides.csv' BOOTSTRAP_SERVERS = ['localhost:9092'] KAFKA_TOPIC = 'rides_json'