Partitioning Development Tutorials, Guides & Insights

Create a producer script (producer.py):

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()

Combine tables to reduce joins in read-heavy systems. Use with care.

Split large tables for better targeting and faster reads.