diff --git a/src/main/java/com/sphere/compentency/kafka/kafkaConsumer.java b/src/main/java/com/sphere/compentency/kafka/kafkaConsumer.java
index 2ff9aca79c82ea1a99ed29a974e372c12face64f..bf3ee8273a9cc3bc53b05e1998171cb2856889a8 100644
--- a/src/main/java/com/sphere/compentency/kafka/kafkaConsumer.java
+++ b/src/main/java/com/sphere/compentency/kafka/kafkaConsumer.java
@@ -81,8 +81,7 @@ public class kafkaConsumer {
                 logger.info("No userIds found in the array");
             }
             // Now, you can pass userIds to your method
-            JSONObject relatedObject = json.getJSONObject("edata").getJSONObject("related");
-            String courseId = relatedObject.getString("courseId");//do_1139628834519941121286,do_11394806141846323211
+            String courseId = json.getJSONObject("edata").getString("courseId");
             logger.info("Processing Kafka message - userId: {}, courseId: {}", userId, courseId);
             api_services.get_hierarchy(courseId, userId);
         } else {
diff --git a/src/main/java/com/sphere/compentency/utils/AppProperties.java b/src/main/java/com/sphere/compentency/utils/AppProperties.java
index 40df67f660581900f794d92fedbe52fd32beba57..4a8bb0b30c07d09024dbd00f1d10bf55069a9dbd 100644
--- a/src/main/java/com/sphere/compentency/utils/AppProperties.java
+++ b/src/main/java/com/sphere/compentency/utils/AppProperties.java
@@ -27,10 +27,4 @@ public class AppProperties {
     @Value("${framework.read}")
     private String frameworkRead;
 
-    @Value("${kafka.output.topic}")
-    private String kafkaOutputTopic;
-
-    @Value("${kafka.output.failed.topic}")
-    private String kafkaFailedOutputTopic;
-
 }
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index f90e62b786963a534798950476b15bebf82ba052..4f1c41c75bcdb4e529394330a4ff4b5c29ea0438 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -1,11 +1,8 @@
 kafka.bootstrapServers=10.0.2.5:9092
 kafka.groupID=dev-activity-aggregate-updater-group
 kafka.input.topic=dev.issue.certificate.request
-kafka.output.topic=dev.generate.certificate.request
-kafka.output.failed.topic=dev.issue.certificate.failed
 
 get.hierarchy=https://uphrh.in/api/course/v1/hierarchy/
-get.entityById=http://localhost:8087/getEntityById/
 passbook.update.url=http://10.155.80.10:9000/private/v1/passbook/update
 host.url=https://uphrh.in/
 framework.read=https://uphrh.in/api/framework/v1/read/nirayama_frccl_fw?categories=difficultyLevel,subject