Updating the kafka topic details (#2836)

* Updating the kafka topic details

* Changing SL to ML

* Updating the naming convention

* Update ml-survey-service.env

* Update ml-core-service.env

* Update ml-projects-service.env

ansible/roles/stack-sunbird/templates/ml-core-service.env

@@ -10,7 +10,7 @@ APPLICATION_ENV={{ml_core_node_env|default("development")}}
 ENABLE_CONSOLE_LOGGING={{ml_core_enable_debug_logging | default("OFF")}}
 
 # Mongo DB Configuration
-MONGODB_URL=mongodb://{{ml_core_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/ml-survey
+MONGODB_URL=mongodb://{{ml_core_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/{{env}}-ml-survey
 
 # Secure token access Admin related API's
 # The value of internal access token can be generated by command - "openssl rand -hex 10

ansible/roles/stack-sunbird/templates/ml-projects-service.env

@@ -11,7 +11,7 @@ INTERNAL_ACCESS_TOKEN={{ml_core_internal_access_token}}
 
 # Mongo db  configurations
 # Mongodb host
-MONGODB_URL=mongodb://{{ml_project_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/ml-survey
+MONGODB_URL=mongodb://{{ml_project_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/{{env}}-ml-survey
 
 # ML Core Service
 ML_CORE_SERVICE_URL={{ml_core_service_url | default("http://ml-core-service:3000")}}                                   
@@ -23,7 +23,7 @@ ML_REPORTS_SERVICE_URL={{ml_report_service_url | default("http://ml-report-servi
 ML_SURVEY_SERVICE_URL={{ml_survey_service_url | default("http://ml-survey-service:3000")}} 
 
 # Kafka topic name to listen for submissions completed against project tasks
-SUBMISSION_TOPIC={{ml_project_submission_topic | default("sl-improvement-project-submission"+env)}}
+SUBMISSION_TOPIC={{ml_project_submission_topic | default(env+".ml.improvement.project.submission")}}
 
 # Kafka enable or disable communication flag
 KAFKA_COMMUNICATIONS_ON_OFF={{ml_project_kafka_communications_on_off | default("ON")}}

ansible/roles/stack-sunbird/templates/ml-reports-service.env

@@ -6,19 +6,19 @@ APPLICATION_PORT={{ml_report_application_port_number | default("3000")}}
 APPLICATION_ENV={{ml_report_node_env | default("development")}}
 
 # Druid connection url
-DRUID_URL={{druid_url | default("http://localhost:9042")}}
+DRUID_URL={{druid_url | default(groups['druid'][0]+':9042')}}
 
 # Observation data source name
-OBSERVATION_DATASOURCE_NAME={{ml_report_observation_datasource_name | default(env+"_sl_observations")}}
+OBSERVATION_DATASOURCE_NAME={{ml_report_observation_datasource_name | default(env+"_ml_observations")}}
 
 # Observation evidences data source name
-OBSERVATION_EVIDENCE_DATASOURCE_NAME={{ml_report_observation_evidence_datasource_name | default(env+"_sl_observation_evidences")}}
+OBSERVATION_EVIDENCE_DATASOURCE_NAME={{ml_report_observation_evidence_datasource_name | default(env+"_ml_observation_evidences")}}
 
 # Survey data source name
-SURVEY_DATASOURCE_NAME={{ml_report_survey_datasource_name | default(env+"_sl_survey_druid")}}
+SURVEY_DATASOURCE_NAME={{ml_report_survey_datasource_name | default(env+"_ml_survey_druid")}}
 
 # Survey evidence data source name
-SURVEY_EVIDENCE_DATASOURCE_NAME={{ml_report_survey_evidence_datasource_name | default(env+"_sl_survey_evidences")}}
+SURVEY_EVIDENCE_DATASOURCE_NAME={{ml_report_survey_evidence_datasource_name | default(env+"_ml_survey_evidences")}}
 
 # Dhiti Thresold Values
 #Restrict number of records to be shown for container reports

ansible/roles/stack-sunbird/templates/ml-survey-service.env

@@ -6,7 +6,7 @@ APPLICATION_PORT={{ml_survey_port | default("3000")}}
 APPLICATION_ENV={{ml_survey_node_env|default("development")}}
 
 # Mongodb connection url
-MONGODB_URL=mongodb://{{ml_survey_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/ml-survey
+MONGODB_URL=mongodb://{{ml_survey_mongodb_url | default(groups['mongo_master'][0]+':27017')}}/{{env}}-ml-survey
 
 # Base url of the sunbird enviornment
 USER_SERVICE_URL={{ml_survey_user_service_URL | default("http://learner-service:9000")}}
@@ -23,25 +23,25 @@ KAFKA_COMMUNICATIONS_ON_OFF={{ml_survey_kafka_communications_on_off | default("O
 KAFKA_URL={{ml_survey_kafka_url | default(groups['processing-cluster-kafka'][0]+':9092')}}
 
 # Kafka topic name for pushing submissions for which rating has to be done
-SUBMISSION_RATING_QUEUE_TOPIC={{ml_survey_submission_rating_queue_topic | default (env+".sl.submission.rating.raw")}}
+SUBMISSION_RATING_QUEUE_TOPIC={{ml_survey_submission_rating_queue_topic | default (env+".ml.submission.rating.raw")}}
 
 # Kafka topic name for pushing completed observation submission
-COMPLETED_OBSERVATION_SUBMISSION_TOPIC={{ml_survey_completed_observation_submission_topic | default (env+".sl.observation.raw")}}
+COMPLETED_OBSERVATION_SUBMISSION_TOPIC={{ml_survey_completed_observation_submission_topic | default (env+".ml.observation.raw")}}
 
 # Kafka topic name for pushing incomplete observation submission
-INCOMPLETE_OBSERVATION_SUBMISSION_TOPIC={{ml_survey_incomplete_observation_submission_topic | default (env+".sl.incomplete.observation.raw")}}
+INCOMPLETE_OBSERVATION_SUBMISSION_TOPIC={{ml_survey_incomplete_observation_submission_topic | default (env+".ml.incomplete.observation.raw")}}
 
 # Kafka topic name for completed survey submission
-COMPLETED_SURVEY_SUBMISSION_TOPIC={{ml_survey_completed_survey_submission_topic | default (env+".sl.survey.raw")}}
+COMPLETED_SURVEY_SUBMISSION_TOPIC={{ml_survey_completed_survey_submission_topic | default (env+".ml.survey.raw")}}
 
 # Kafka topic name for incomplete survey submission
-INCOMPLETE_SURVEY_SUBMISSION_TOPIC={{ml_survey_incomplete_survey_submission_topic | default (env+".sl.incomplete.observation.raw")}}
+INCOMPLETE_SURVEY_SUBMISSION_TOPIC={{ml_survey_incomplete_survey_submission_topic | default (env+".ml.incomplete.observation.raw")}}
 
 # Kafka consumer group for ML Survey Service
 KAFKA_GROUP_ID={{ml_survey_kafka_group_id | default (env+"samiksha")}}
 
 #  Kafka topic name for pushing project submission related data
-IMPROVEMENT_PROJECT_SUBMISSION_TOPIC={{ml_survey_improvement_project_submission_topic | default(env+".sl.improvement.project.submission")}}
+IMPROVEMENT_PROJECT_SUBMISSION_TOPIC={{ml_survey_improvement_project_submission_topic | default(env+".ml.improvement.project.submission")}}
 
 # Elastic search configurations 
 # Elastic search enable/disable flag E.g. ON/OFF