DeveloperBreeze

Distributed Systems Development Tutorials, Guides & Insights

Unlock 1+ expert-curated distributed systems tutorials, real-world code snippets, and modern dev strategies. From fundamentals to advanced topics, boost your distributed systems skills on DeveloperBreeze.

Building a Scalable Event-Driven System with Kafka

Tutorial December 10, 2024
python

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.