Code RoomKafka partition lag grows unbounded
HardPrep Room Coding #4545

Kafka partition lag grows unbounded

On-callDistributed systemsSenior–Staff~40 min

A Kafka consumer group (Java) processes an events topic with 12 partitions, in-order per partition. At 13:00 consumer lag on exactly one partition starts growing unboundedly while the other 11 partitions stay at near-zero lag. Throughput on that one partition collapsed. Logs from the consumer assigned to that partition show it repeatedly trying to process the same message offset, throwing, and retrying — it never commits past that offset. A producer started emitting a new event type at 12:55. Triage and mitigate.

What a strong answer looks like

Stop the bleeding first (mitigate), then form hypotheses from real signals. Separate root cause from symptom, communicate status as you go, and close with what prevents a repeat.

0:00 of about 40 min
Which questions mattered is sealed until you submit. Telling you now would just be handing over the edge cases.