From 07418603d16d29e750df044381b589a593d95816 Mon Sep 17 00:00:00 2001
From: gulnaz <tarkhanova@micord.ru>
Date: Tue, 25 Nov 2025 22:13:04 +0300
Subject: [PATCH] SUPPORT-9561: fix listener

---
 .../micord/ervu/kafka/listener/ExcerptListener.java | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/backend/src/main/java/ru/micord/ervu/kafka/listener/ExcerptListener.java b/backend/src/main/java/ru/micord/ervu/kafka/listener/ExcerptListener.java
index 1a9a4241..015c2783 100644
--- a/backend/src/main/java/ru/micord/ervu/kafka/listener/ExcerptListener.java
+++ b/backend/src/main/java/ru/micord/ervu/kafka/listener/ExcerptListener.java
@@ -1,10 +1,13 @@
 package ru.micord.ervu.kafka.listener;
 
+import java.util.UUID;
 import java.util.concurrent.atomic.AtomicReference;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Service;
 import ru.micord.ervu.audit.constants.AuditConstants;
 import ru.micord.ervu.audit.service.AuditService;
 import ru.micord.ervu.dao.ExcerptHistoryDao;
@@ -17,6 +20,7 @@ import ru.micord.ervu.util.UrlUtils;
 /**
  * @author gulnaz
  */
+@Service
 public class ExcerptListener {
 
   @Autowired
@@ -28,8 +32,11 @@ public class ExcerptListener {
   @Autowired
   private AuditService auditService;
 
+  @Value("${ervu.kafka.group.id}")
+  private String groupId;
+
   @KafkaListener(
-      id = "${ervu.kafka.group.id}",
+      id = "#{excerptListener.getGroupId}",
       topics = "${ervu.kafka.excerpt.reply.topic}",
       containerFactory = "fileContainerFactory")
   public void listen(String kafkaResponse) {
@@ -79,4 +86,8 @@ public class ExcerptListener {
       throw new ExcerptException(e);
     }
   }
+
+  public String getGroupId() {
+    return groupId + "-" + UUID.randomUUID();
+  }
 }