DeveloperBreeze

Scalable Architecture Development Tutorials, Guides & Insights

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

Tutorial
python

Building a Scalable Event-Driven System with Kafka

Create a consumer script (consumer.py):

from confluent_kafka import Consumer

conf = {
    'bootstrap.servers': "localhost:9092",
    'group.id': "order_group",
    'auto.offset.reset': 'earliest'
}

consumer = Consumer(conf)
consumer.subscribe(["orders"])

while True:
    msg = consumer.poll(1.0)
    if msg is None:
        continue
    if msg.error():
        print(f"Consumer error: {msg.error()}")
        continue

    print(f"Received message: {msg.value().decode('utf-8')}")

consumer.close()

Dec 10, 2024
Read More