Page History

@startuml
hide footbox
skinparam maxMessageSize 70

participant  "Heartbeat\nRequest\nManager" as HRM
participant  "Member\nState"               as MS
participant  "Assignment\nReconciler"      as AR
participant  "Revoke\nPartitions\nEvent"   as RPE
queue        "Backend\nEvent\nQueue"       as BEQ
skinparam maxMessageSize 70

HRM -> MS: heartbeat received
activate MS
  MS -> AR: updateAssignment()
  activate AR
    AR -> AR: calculateRevoked()
    create RPE
    AR -> RPE : new
    AR -> BEQ : add()
    return
  return

@enduml

@startuml
hide footbox
skinparam maxMessageSize 70

actor        User as                           as U
participant  ProtoAsyncConsumer              as PAC
participant  "Revoke\nPartitions\nEvent"     as RPE
participant  "Partitions\nRevoked\nEvent"    as PRE
participant  "Consumer\nRebalance\nListener" as CRL
queue        "Application\nEvent\nQueue"     as AEQ
queue        "Backend\nEvent\nQueue"         as BEQ
skinparam maxMessageSize 70

U -> PAC: poll()
activate PAC
  PAC -> BEQ: poll()
  activate BEQ
    return

  PAC -> PAC: process background events
  ...

  PAC -> RPE: partitions()
  activate RPE
    return

  PAC -> CRL: partitionsRevoked()
  activate CRL
    return

  create PRE
  PAC -> PRE : new
  PAC -> AEQ : add()
  activate AEQ
    return

  return
@enduml