Merge pull request #11 from reshmi-nair/main

Fixing type casting issue for userId while reading from kafka event

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 {

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

src/main/resources/application.properties

 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