producer.py

from confluent_kafka import Producer
from faker import Faker
from time import sleep

fake = Faker()

def delivery_report(err, msg):
    if err != None:
        print('Message delivery failed: {}'.format(err))
    else:
        print('Message delivered to topic: {}, partition: [{}]'.format(msg.topic(), msg.partition()))


kafka_advanced_listener = 'PLAINTEXT://localhost:29092'
topic_name = 'my_topic'


p = Producer(
    {'bootstrap.servers': kafka_advanced_listener}
)

while True:
    for data in [fake.name() for i in range(5)]:
        g = p.poll(0)

        p.produce(
            topic=topic_name,
            value=data.encode('utf-8'),
            callback=delivery_report
            
        )

    p.flush()
    sleep(3)