From a25f76f6ddeedf12bf905b03e30a06b3841e3413 Mon Sep 17 00:00:00 2001
From: Raja Kolli <rajadilipkolli@gmail.com>
Date: Thu, 26 Dec 2024 07:46:57 +0000
Subject: [PATCH] updates seq diagram

---
 .../boot-concurrent-kafka-consumer/ReadMe.md           | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/kafka-spring-boot/boot-concurrent-kafka-consumer/ReadMe.md b/kafka-spring-boot/boot-concurrent-kafka-consumer/ReadMe.md
index 1d716d05..512ee2cc 100644
--- a/kafka-spring-boot/boot-concurrent-kafka-consumer/ReadMe.md
+++ b/kafka-spring-boot/boot-concurrent-kafka-consumer/ReadMe.md
@@ -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
 ```