diff --git a/ansible/roles/monasca/templates/monasca-log-persister/log-persister.conf.j2 b/ansible/roles/monasca/templates/monasca-log-persister/log-persister.conf.j2
index 31b08d3c5f46451be305c9a9fcb41a2db79b9006..6eb9219b4c17b24f97797fdb87c9b3795f5abfdd 100644
--- a/ansible/roles/monasca/templates/monasca-log-persister/log-persister.conf.j2
+++ b/ansible/roles/monasca/templates/monasca-log-persister/log-persister.conf.j2
@@ -4,7 +4,9 @@ input {
     kafka {
         zk_connect => "{{ monasca_zookeeper_servers }}"
         topic_id => "{{ monasca_transformed_logs_topic }}"
-        group_id => "transformer-logstash-consumer"
+        group_id => "log_persister"
+        consumer_id => "log_persister_{{ ansible_hostname }}"
+        consumer_threads => "{{ monasca_log_pipeline_threads }}"
     }
 }
 
diff --git a/ansible/roles/monasca/templates/monasca-log-persister/monasca-log-persister.json.j2 b/ansible/roles/monasca/templates/monasca-log-persister/monasca-log-persister.json.j2
index 3eb19fa42d1a5be420f0140ebdcf3f837b69991d..fa99a35d204d91a42818e480930ce247e42403cf 100644
--- a/ansible/roles/monasca/templates/monasca-log-persister/monasca-log-persister.json.j2
+++ b/ansible/roles/monasca/templates/monasca-log-persister/monasca-log-persister.json.j2
@@ -1,5 +1,5 @@
 {
-    "command": "/usr/share/logstash/bin/logstash --log-in-json --log /var/log/kolla/monasca/monasca-log-persister.log -f /etc/logstash/conf.d/log-persister.conf",
+    "command": "/opt/logstash/bin/logstash --log-in-json --log /var/log/kolla/logstash/monasca-log-persister.log -f /etc/logstash/conf.d/log-persister.conf",
     "config_files": [
         {
             "source": "{{ container_config_directory }}/log-persister.conf",
@@ -16,7 +16,7 @@
     ],
     "permissions": [
         {
-            "path": "/var/log/kolla/monasca",
+            "path": "/var/log/kolla/logstash",
             "owner": "logstash:kolla",
             "recurse": true
         }