kafka-consumer-group-stuck-restart

The procedure as a graph, on its own page — zoom it, print it, send somebody the address. Back to the record for the steps, the trust panel and the provenance.

Procedure

The same procedure, read in order

  1. start start. Goes next to s1
  2. check Capture current lag. Goes on_fail to s9; next to s2
  3. decision Determine lag spread. Goes if all to s3; if single to s4; if default to s9
  4. action Restart the consumer group, RW (reversible-write). Goes next to s5
  5. check Inspect the lagging partition. Goes on_fail to s9; next to s5
  6. escalate Escalate to the platform team. Terminal
  7. wait Wait for offsets to advance. Goes retry to s5; next to __end_success
  8. end success. Terminal