From 81d43c48ee52704d17268b6c269e28b52a82b12a Mon Sep 17 00:00:00 2001
From: ashok-ksharma <ashok@mosip.io>
Date: Sat, 19 Jul 2025 22:29:52 +0530
Subject: [PATCH] =?UTF-8?q?Revert=20"[MOSIP-41319]=20-=20Kafka=20Rebalance?=
 =?UTF-8?q?=20Issue=20-=20Kafka=20Message=20Key=20Creation=20fi=E2=80=A6"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

This reverts commit a396135105b5c5dfb0369681d465526b37669ad2.
---
 .../processor/core/eventbus/KafkaMosipEventBus.java             | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/eventbus/KafkaMosipEventBus.java b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/eventbus/KafkaMosipEventBus.java
index 846ba2d3fde..5b290a6033c 100644
--- a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/eventbus/KafkaMosipEventBus.java
+++ b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/eventbus/KafkaMosipEventBus.java
@@ -346,7 +346,7 @@ Future<Void> processRecord(MessageBusAddress toAddress,
 					JsonObject jsonObject = JsonObject.mapFrom(messageDTO);
 					KafkaProducerRecord<String, String> producerRecord = 
 						KafkaProducerRecord.create(messageBusToAddress.getAddress(), 
-							messageDTO.getRid()+ "_" + messageBusToAddress.getAddress() + (messageDTO.getMessageBusAddress().getAddress() != null ? "_"  + messageDTO.getMessageBusAddress().getAddress() : "") , jsonObject.toString());
+							messageDTO.getRid()+ "_" + messageBusToAddress.getAddress(), jsonObject.toString());
 					this.eventTracingHandler.writeHeaderOnKafkaProduce(producerRecord, span);
 					kafkaProducer.write(producerRecord, handler -> {
 						MDC.setContextMap(mdc);