ErrorManagementPattern/RetryFlow2.wsd at master · buidiaconseil/ErrorManagementPattern · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
@startuml

group Kafka Stream Processed
entity RetryStream
entity Offset
entity PrincipalStream

end


control Producer
control Consumer
collections  RetryManager


loop on partition

RetryManager -> Consumer : poll one second
RetryStream <- Consumer : Get Records
RetryStream -> Consumer : Get Records
RetryManager <- Consumer : Get Records
loop on records

    RetryManager -> RetryManager : Get Next Record
    RetryManager -> RetryManager : Is it time ?
    alt successful
        RetryManager -> Producer : push the payload
        Producer -> PrincipalStream : push the record
        Producer <- PrincipalStream
        RetryManager <- Producer
        RetryManager -> Consumer : Commit Partition
        Consumer -> Offset : push and commit
        Consumer <- Offset
        RetryManager <- Consumer
    else
        RetryManager->RetryManager: go to the next partition/record
    end


end

end


@enduml