Skip to content

Commit

Permalink
updates seq diagram
Browse files Browse the repository at this point in the history
  • Loading branch information
rajadilipkolli committed Dec 26, 2024
1 parent 3c785e5 commit a25f76f
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions kafka-spring-boot/boot-concurrent-kafka-consumer/ReadMe.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,21 @@ sequenceDiagram
participant P as ToUpperStringProcessor
C->>C: Spring Boot initializes application
Note over C: Configure concurrent consumers
C->>A: Kafka messages arrive, triggering onMessage()
par Thread 1
A->>A: Retrieve or initialize ThreadLocal<ToUpperStringProcessor>
A->>P: processString(value)
P->>P: Converts to uppercase & enqueues result
and Thread 2
A->>A: Retrieve or initialize ThreadLocal<ToUpperStringProcessor>
A->>P: processString(value)
P->>P: Converts to uppercase & enqueues result
end
Note over A,P: Additional messages handled similarly
alt Error occurs
A->>A: Handle error & retry/dead letter
end
A->>A: onEvent(ConsumerStoppedEvent) -> Remove ThreadLocal processor
```

Expand Down

0 comments on commit a25f76f

Please sign in to comment.