ml_kafka_create_producer_1.py

# importing packages
import pandas as pd
import time, json
import datetime as dt
import requests
from kafka import KafkaProducer

df = pd.read_csv("spam.csv")

# initializing Kafka Producer Client
producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                         value_serializer=lambda x:
                         json.dumps(x,default=str).encode('utf-8'))

print(f'Initialized Kafka producer at {dt.datetime.utcnow()}')