Merge pull request #44 from prasadmoka/local-5.0.0

fix:LR-105 added kafka topic variables to lern pipeline

ansible/inventory/env/group_vars/all.yml

@@ -7,7 +7,6 @@ ansible_vault_password: "{{lp_vault_ansible_vault_password}}"
 secrets_path: '{{inventory_dir}}/group_vars/common.yml'
 
 env_name: "{{ env }}"
-bb: lern
 instance_name: "{{ env }}"
 instance: "{{ env }}"
 cert_env_prefix : "{{ instance }}"
@@ -121,4 +120,34 @@ enable_suppress_exception: false
 enable_rc_certificate: true
 
 ### kafka and zookeeper ip vars and being used in kafka topiccreation role.
-processing_zookeeper_ip: "{{ groups['processing-cluster-zookeepers'][0] }}"
\ No newline at end of file
+processing_zookeeper_ip: "{{ groups['processing-cluster-zookeepers'][0] }}"
+## MultiDC flag for LERN data pipeline jobs
+is_multidc_enabled: false
+
+# LERN BB specific kafka topics,have to be overridden in private devops repo to include BB Name for integrators.
+kafka_topic_course_batch_job_request: "{{env_name}}.coursebatch.job.request"
+kafka_topic_certificate_request: "{{env_name}}.issue.certificate.request"
+kafka_topic_contentstate_invalid: "{{env_name}}.contentstate.invalid"
+kafka_topic_enrolment_sync_request: "{{env_name}}.batch.enrolment.sync.request"
+kafka_topic_assessment: "{{env_name}}.telemetry.assess"
+kafka_topic_telemetry_raw:  "{{env_name}}.telemetry.raw"
+kafka_topic_activity_agg_failed: "{{env_name}}.activity.agg.failed"
+kafka_topic_content_publish_request: "{{env_name}}.content.postpublish.request"
+kafka_topic_generate_certificate_request: "{{env_name}}.generate.certificate.request"
+kafka_topic_certificate_failed: "{{env_name}}.issue.certificate.failed"
+kafka_topic_lms_user_account: "{{env_name}}.lms.user.account.merge"
+kafka_topic_learning_failed: "{{env_name}}.learning.events.failed"
+kafka_topic_assessment_failed: "{{env_name}}.telemetry.assess.failed"
+kafka_topic_lms_notification: "{{env_name}}.lms.notification"
+kafka_topic_enrolment_reconciliation_failed: "{{env_name}}.enrolment.reconciliation.failed"
+kafka_topic_generate_certificate_failed: "{{env_name}}.generate.certificate.failed"
+
+## LERN BB specific kafka groups,have to be overridden in private devops repo to include BB Name for integrators.
+kafka_group_activity_agg: "{{env_name}}-activity-aggregate-group"
+kafka_group_relation_cache_updater: "{{env_name}}-relation-cache-updater-group"
+kafka_group_enrolment_reconciliation: "{{env_name}}-enrolment-reconciliation-group"
+kafka_group_collection_pre_processor: "{{env_name}}-collection-cert-pre-processor-group"
+kafka_group_certificate_generator: "{{env_name}}-certificate-generator-group"
+kafka_group_merge_courses: "{{env_name}}-merge-courses-group"
+kafka_group_assessment_aggregator: "{{env_name}}-assessment-aggregator-group"
+kafka_group_lms_notification: "{{env_name}}-lms-notification"
\ No newline at end of file