Added new kafka topics in main.yml and config.j2

project-sunbird · Feb 28, 2024 · c3be1c8 · c3be1c8
1 parent 3fb0c3e
commit c3be1c8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/ansible/roles/ml-analytics-service/defaults/main.yml b/ansible/roles/ml-analytics-service/defaults/main.yml
@@ -138,3 +138,7 @@ ml_analytics_batch_cron_hour: "{{ ml_batch_cron_hour | default('18') }}"
 ml_analytics_nvsk_cron_minute: "{{ ml_nvsk_cron_minute | default('30') }}"
 ml_analytics_nvsk_cron_hour: "{{ ml_nvsk_cron_hour | default('7') }}"
 ml_analytics_nvsk_cron_weekday: "{{ ml_nvsk_cron_weekday | default('4') }}"
+ml_analytics_survey_meta_druid_topic_name : "{{ env_name }}.ml.survey.meta"
+ml_analytics_survey_completed_druid_topic_name : "{{ env_name }}.ml.survey.status.completed"
+ml_analytics_survey_started_druid_topic_name : "{{ env_name }}.ml.survey.status.started"
+ml_analytics_survey_inprogress_druid_topic_name : "{{ env_name }}.ml.survey.status.inprogress"
diff --git a/ansible/roles/ml-analytics-service/templates/config.j2 b/ansible/roles/ml-analytics-service/templates/config.j2
@@ -130,6 +130,13 @@ survey_raw_topic = {{ ml_analytics_kafka_survey_topic_name }}
 
 survey_druid_topic = {{ ml_analytics_kafka_survey_druid_topic_name }}
 
+survey_meta_druid_topic = {{ ml_analytics_survey_meta_druid_topic_name }}
+
+survey_completed_druid_topic = {{ ml_analytics_survey_completed_druid_topic_name }}
+
+survey_started_druid_topic = {{ ml_analytics_survey_started_druid_topic_name }}
+
+survey_inprogress_druid_topic = {{ ml_analytics_survey_inprogress_druid_topic_name }}
 
 [LOGS]