From a3a5fd3180cf87b1d7ca044ec0bda2215bee30f1 Mon Sep 17 00:00:00 2001
From: Andrii Landiak <andriylandiak@gmail.com>
Date: Wed, 25 Jun 2025 16:59:31 +0300
Subject: [PATCH] Small refactoring of sendErrorResponse

---
 .../queue/common/PartitionedQueueResponseTemplate.java       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/common/PartitionedQueueResponseTemplate.java b/common/queue/src/main/java/org/thingsboard/server/queue/common/PartitionedQueueResponseTemplate.java
index a15fafa19a..ef1682b97f 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/common/PartitionedQueueResponseTemplate.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/common/PartitionedQueueResponseTemplate.java
@@ -131,7 +131,7 @@ public class PartitionedQueueResponseTemplate<Request extends TbQueueMsg, Respon
                                     @Override
                                     public void onFailure(Throwable t) {
                                         log.error("[{}] Failed to send response {}", requestId, response, t);
-                                        sendErrorResponse(requestId, responseTopic, request, t);
+                                        sendErrorResponse(requestId, tpi, request, t);
                                         stats.incrementFailed();
                                     }
                                 });
@@ -158,12 +158,11 @@ public class PartitionedQueueResponseTemplate<Request extends TbQueueMsg, Respon
         consumer.commit();
     }
 
-    private void sendErrorResponse(UUID requestId, String responseTopic, Request request, Throwable cause) {
+    private void sendErrorResponse(UUID requestId, TopicPartitionInfo tpi, Request request, Throwable cause) {
         Response errorResponseMsg = handler.constructErrorResponseMsg(request, cause);
 
         if (errorResponseMsg != null) {
             errorResponseMsg.getHeaders().put(REQUEST_ID_HEADER, uuidToBytes(requestId));
-            TopicPartitionInfo tpi = TopicPartitionInfo.builder().topic(responseTopic).build();
             responseProducer.send(tpi, errorResponseMsg, null);
         }
     }