live
Partition three is having a day
Kafka consumer lag: one partition at 1.4M, every other partition near zero. Rebalancing does nothing.
The scene
Reported: orders-events consumer group lag alert:
PARTITION LAG
0 41
1 12
2 77
3 1,402,777
4..7 < 100- Adding consumers and forcing a rebalance doesn't help: whichever consumer gets partition 3 lags, the rest sit idle.
- Last night, data engineering ran a backfill that replayed 2M historical orders through the same producer.
- Producer code:
producer.send("orders-events", key=str(order.customer_ref), value=...). - In historical data,
customer_refisNonefor guest checkouts, which was most orders before 2022.
Diagnoses — hidden until the incident closes
Sign in to post your root-cause diagnosis.