Test-Kafka

Tạo topic "views" với 3 partition

producer.py

for number in range(100):
    data = {'number': number}
    data = json.dumps(data)

    p.produce(topic, data, callback=delivery_callback)
    p.poll(0)

    sys.stderr.write('%% Waiting for %d deliveries\n' % len(p))
    p.flush()

Bên trong producer.py vòng for lần lượt theo thứ tự từ 1-100 nhưng consumer lại nhận kết quả theo thứ tự khác

Phân bố message giữa các partition cũng không đồng đều