| import json | |
| from kafka import KafkaProducer | |
| import time | |
| kafka_server = 'localhost:9092' | |
| producer = KafkaProducer(bootstrap_servers=kafka_server, value_serializer=lambda v: json.dumps(v).encode('utf-8')) | |
| with open('f1_race_data/f1_data_2022.json') as json_file: | |
| for line in json_file: | |
| json_object = json.loads(line) | |
| producer.send('F1Topic', json_object) | |
| print(json_object) | |
| time.sleep(3) | |