Kafka, Kafka Consumer, Kafka Producer, Confluent Kafka, Streaming.
__name__ == '__main__': rides = read_csv(resource_path=DATA_PATH) producer = SimpleProducer(props=CONFLUENT_CLOUD_CONFIG) producer.publish(topic=TOPIC, messages=rides) Below code snippets represent the content of the utils.py file and define the functionality of reading CSV files locally and