from confluent_kafka import Producer
conf = {'bootstrap.servers': "localhost:9092"}
producer = Producer(conf)
def delivery_report(err, msg):
if err:
print(f"Delivery failed: {err}")
else:
print(f"Message delivered to {msg.topic()} [{msg.partition()}]")
producer.produce("orders", key="order_1", value="Order Placed", callback=delivery_report)
producer.flush()
Consumers read and process events from Kafka topics.