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);