diff --git a/ansible/roles/monasca/defaults/main.yml b/ansible/roles/monasca/defaults/main.yml
index d3921538146846013e3960335c20617d47692225..ac81421296d8b63f2758d8c4b15b8cf6251c919f 100644
--- a/ansible/roles/monasca/defaults/main.yml
+++ b/ansible/roles/monasca/defaults/main.yml
@@ -36,6 +36,9 @@ monasca_influxdb_http_port: "{{ influxdb_http_port }}"
 monasca_kafka: "{% for host in groups['kafka'] %}{{ hostvars[host]['ansible_' + hostvars[host]['api_interface']]['ipv4']['address'] }}:{{ kafka_port }}{% if not loop.last %},{% endif %}{% endfor %}"
 monasca_memcached_servers: "{% for host in groups['memcached'] %}{{ hostvars[host]['ansible_' + hostvars[host]['api_interface']]['ipv4']['address'] }}:{{ memcached_port }}{% if not loop.last %},{% endif %}{% endfor %}"
 
+monasca_metrics_topic: "metrics"
+monasca_raw_logs_topic: "logs"
+
 ####################
 # Docker
 ####################
diff --git a/ansible/roles/monasca/templates/monasca-api/api-config.conf.j2 b/ansible/roles/monasca/templates/monasca-api/api-config.conf.j2
index d05e38f961d9c9323dff4a514d9493308825ea3a..d78c1c7a9f21c5cbb11f22da86ae73778c151e07 100644
--- a/ansible/roles/monasca/templates/monasca-api/api-config.conf.j2
+++ b/ansible/roles/monasca/templates/monasca-api/api-config.conf.j2
@@ -14,6 +14,7 @@ ip_address = {{ monasca_influxdb_address }}
 port = {{ monasca_influxdb_http_port }}
 
 [kafka]
+metrics_topic = {{ monasca_metrics_topic }}
 partitions = 0
 uri = {{ monasca_kafka }}
 
diff --git a/ansible/roles/monasca/templates/monasca-log-api/log-api.conf.j2 b/ansible/roles/monasca/templates/monasca-log-api/log-api.conf.j2
index 82fe7e68de12963de4d7981ac92698cb1476e2f3..c542060a200cd01eaf9b5cad267d544d147a9bff 100644
--- a/ansible/roles/monasca/templates/monasca-log-api/log-api.conf.j2
+++ b/ansible/roles/monasca/templates/monasca-log-api/log-api.conf.j2
@@ -4,9 +4,11 @@ log_dir = /var/log/kolla/monasca
 debug = {{ monasca_logging_debug }}
 
 [kafka_healthcheck]
+kafka_topics = {{ monasca_raw_logs_topic }}
 kafka_url = {{ monasca_kafka }}
 
 [log_publisher]
+topics = {{ monasca_raw_logs_topic }}
 kafka_url = {{ monasca_kafka }}
 
 [monitoring]