ml_kafka_create_producer_2.py

for i in df.index:

    # Create a message that includes a message ID and email text
    data = {'MessageID': str(i),
            'MessageBody': df['Message'][i]}
            
    # Print the message so you can see what is being sent
    print(f'Sending message: {data}')
    
    # Send the data with the KafkaProducer client
    producer.send(topic="emails", value=data)

print(f'Sent record to topic at time {dt.datetime.utcnow()}')