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
actor User asas U participant ProtoAsyncConsumeras 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